Use asynchronous non-blocking database access using the sql client provided by vertx. Then you organize your project so that it is easy to use without giving up the SQL Mapper framework (MyBatis) ORM framework.
The code block below is an example of a pure sql client code provided by vertx. I wanted to build an sql service using (without giving up) an SQL Mapper framework like mybatis.
final SQLConnection connection = conn.result();
connection.queryWithParams("select * from test where id = ?", new JsonArray().add(2), rs -> {
...
});Once you have mybatis sqlsession, you can use BoundSql and ParameterMapping methods to retrieve queries and parameters and use them in your vertex sql client. See QueryGetter.java
- org.apache.ibatis.mapping.BoundSql
- org.apache.ibatis.mapping.ParameterMapping
// Get BoudSql
BoundSql boundSql = sqlsession.getConfiguration()
.getMappedStatement(sqlName) // MyBatis SQL ID
.getSqlSource()
.getBoundSql(reqData)
;
// A query containing '?' Is returned.
queryString = boundSql.getSql();
// The parameters defined in the mapper are returned.
List<ParameterMapping> paramMapping = boundSql.getParameterMappings();
for ( ParameterMapping mapping : paramMapping ) {
String key = mapping.getProperty();
Object value = ((Map<String,Object>)reqData).get(key);
}Provides boilerplate for developers to create sql only and make it easy to access api server easily.
- Create or Edit MyBatis mapper.xml
- URL
- C: /api/create, R: /api/read, U: /api/update, D: /api/delete
- Batch C: /api/create/multi, U: /api/update/multi, D: /api/delete/multi
- HTTP POST method Call
header --> "Authorization": "Bearer `JWT Token`" // It can be obtained through "/api/newToken" service.
payload = {
sqlName: 'sqlid', // mybatis sql id
param1: 'foo',
param2: 'bar',
...
}
Use mysql-binlog-connector-java & Inspired by vertx-mysql-binlog-client
Thanks!!
Unlike the vertx-mysql-binlog-client, however, it does not release row-level events, but instead emit events in TR range.
Recently, we had to add a large Excel download to an existing web application that had a lot of side effects when adding services.
- Invoke the REST API with parameters including the number of patches to the legacy application (Spring framework), assuming 50,000 data requests.
- Establish appropriate paging rules (eg, 10,000 responses) to invoke the DB service by dividing 50,000 requests into 10,000 requests.
- Call the DB service n times as defined in step 2.
- Use vertex sql client to process asynchronous non-block.
- Process vertex cvs parsing using queryStream () of vertx and generate csv file asynchronously using vertex fileSystem () feature. You can see that the processed result is different to the order requested, as shown by the arrow in the figure. (AsyncResult)
- CompositeFuture.all () is used to wait for the future of all the processing results, and then batches the response processing.
- Get the csv file path list in the Legacy Application.
- Stream the HTTP chunked response with the file list in step 7.
- Related Codes
public void main () {
.
├── bin
│ ├── build.sh // Maven build script
│ ├── config-to-server.sh // Apply server properties
│ ├── memchk.sh // Linux Server Target Process Memory View
│ └── run.sh // This application start and stop script
├── pom.xml
├── run.bat
└── src
└── main
├── java
│ └── io
│ └── frjufvjn
│ └── lab
│ └── vertx_mybatis
│ ├── AppMain.java // Direct Execute Application in IDE Without CLI
│ ├── BareInstance.java
│ ├── Constants.java
│ ├── MainVerticle.java // Main Verticle
│ ├── SubVerticle.java
│ ├── common
│ │ ├── ApiErrorType.java
│ │ ├── ApiRequestCommon.java // API Request
│ │ └── ApiResponseCommon.java // API Response
│ ├── factory
│ │ ├── MyBatisConnectionFactory.java // MyBatis Connection
│ │ └── VertxSqlConnectionFactory.java // Vertx JDBC Client Connection
│ ├── mysqlBinlog
│ │ ├── BinLogClientVerticle.java
│ │ ├── BinlogEventType.java
│ │ └── SchemaService.java
│ ├── query
│ │ ├── QueryModule.java
│ │ ├── QueryServiceImp.java // Query Getter Using Mybatis
│ │ └── QueryServices.java
│ ├── secure
│ │ ├── CryptoManager.java
│ │ ├── CryptoModule.java
│ │ └── CryptoService.java
│ └── sql
│ ├── EBSqlServiceVerticle.java // eventbus sql verticle
│ ├── SqlServiceImp.java // API DB Service implement
│ └── SqlServices.java
├── js
│ └── jsVerticle.js
└── resources
├── config
│ ├── app.properties // application property
│ ├── db-config.xml // mybatis config
│ ├── db.properties // db connection information property
│ ├── db.properties.SAMPLE
│ ├── keystore.jceks
│ ├── pubsub-mysql-server.json // mysql pubsub server connection config
│ └── pubsub-mysql-service.json // mysql pubsub service config
├── log4j2.xml // log4j2 log
├── mapper
│ ├── test.xml // mybatis mapper xml
│ └── users.xml
├── vertx-default-jul-logging.properties // JUL log (not use in this project)
└── webroot
├── dbRTC.js
├── index.html // API Service Test Page (http://localhost:18080)
├── sha256.js
└── ws-test.html
}$ cd bin
$ ./config-to-server.sh # That's because the author's development machine is Windows.
$ ./build.sh$ cd bin
$ ./run.sh [start/stop/status] # execute vertx-fat.jar> mvn install
> mvn clean package -f ./pom.xml> run.bat # execute vertx-fat.jarMIT