mxsm commented on PR #4332: URL: https://github.com/apache/eventmesh/pull/4332#issuecomment-1689159932
@HattoriHenzo Thanks for the visual illustration!  1. JdbcConnection provides a wrapper for java.sql, such as obtaining a connection, setting the connection's autocommit property, and more. For specific database queries, JdbcConnection can be subclassed for implementation. JdbcConnection provides general interfaces for things like executing SQL statements. 2. The connection factory is responsible for creating JdbcConnection connections. Here, java.sql.DriverManager is used to automatically load database drivers based on the jdbc protocol configured in a configuration file. 3. For the Jdbc Source, since it needs to support Cdc, the implementation of Cdc is different for different data types. The relevant configuration for Cdc for a specific database is added in the Source configuration file. 4. The JDBC Sink is mainly responsible for inserting data into the corresponding database. Only the general configuration for JDBC needs to be configured, and then the data from the Source is converted into the data needed by the Sink based on the type of database and saved. The overall architecture design is basically the same as yours, but there are some differences in nomenclature and implementation details. I will split the PR into smaller chunks to facilitate code review by others. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
