pom.xml

结构

<properties><maven.compiler.source>8</maven.compiler.source><maven.compiler.target>8</maven.compiler.target><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><mysql5>5.1.44</mysql5><mysql8>8.0.30</mysql8><hikari.version>4.0.3</hikari.version>
</properties><dependencies><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>2.0.7</version></dependency><dependency><groupId>com.zaxxer</groupId><artifactId>HikariCP</artifactId><version>${hikari.version}</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql8}</version></dependency>
</dependencies>

basic

DbInfo.java

就是一个普通的bean，记录jdbc的连接信息

@Data
@Builder
public class DbInfo {private String jdbcUrl;private String username;private String password;private String driverClassName;
}

AbstractContainerDatabase.java

生成一个连接池，可用于执行sql

public class AbstractContainerDatabase {protected ResultSet performQuery(DbInfo info, String sql) throws SQLException {DataSource ds = getDataSource(info);Statement statement = ds.getConnection().createStatement();statement.execute(sql);ResultSet resultSet = statement.getResultSet();resultSet.next();return resultSet;}protected DataSource getDataSource(DbInfo info) {HikariConfig hikariConfig = new HikariConfig();hikariConfig.setJdbcUrl(info.getJdbcUrl());hikariConfig.setUsername(info.getUsername());hikariConfig.setPassword(info.getPassword());hikariConfig.setDriverClassName(info.getDriverClassName());return new HikariDataSource(hikariConfig);}
}

mysql

MysqlInfo.java

由于各种JDBC使用的驱动不一样。所以构建一个Mysqlnfo类，负责生成MySQL所使用的Dbinfo。由于MySQL版本可能不一样，这里提供了不同版本的dbInfo。

public class MysqlInfo {private static final String MYSQL_JDBC_URL_TEMPLATE = "jdbc:mysql://%s:%s/%s";private static final String MYSQL_V5_DRIVER_CLASS = "com.mysql.jdbc.Driver";private static final String MYSQL_V8_DRIVER_CLASS = "com.mysql.cj.jdbc.Driver";public static DbInfo getMysql5Info(String host, int port, String username, String password, String db) {return DbInfo.builder().jdbcUrl(String.format(MYSQL_JDBC_URL_TEMPLATE, host, port, db)).username(username).password(password).driverClassName(MYSQL_V5_DRIVER_CLASS).build();}public static DbInfo getMysql8Info(String host, int port, String username, String password, String db) {return DbInfo.builder().jdbcUrl(String.format(MYSQL_JDBC_URL_TEMPLATE, host, port, db)).username(username).password(password).driverClassName(MYSQL_V8_DRIVER_CLASS).build();}
}

MysqlTest.java

测试类，这里集成了前面的AbstractContainerDatabase，直接构造一个DbInfo，然后new一个自己，就可以直接调用performQuery来执行SQL了。

public class MysqlTest extends AbstractContainerDatabase {private static final Logger LOG = LoggerFactory.getLogger(MysqlTest.class);public static void main(String[] args) throws SQLException {DbInfo mysql8Info = MysqlInfo.getMysql8Info("host", 3306, "user", "passwd", "tmp");MysqlTest mysqlTest = new MysqlTest();ResultSet resultSet = mysqlTest.performQuery(mysql8Info, "select * from test");// 输出表结构信息ResultSetMetaData metaData = resultSet.getMetaData();int columnCount = metaData.getColumnCount();LOG.info("Table Structure is :");for (int i = 1; i <= columnCount; i++) {String columnName = metaData.getColumnName(i);String columnType = metaData.getColumnTypeName(i);int columnLength = metaData.getColumnDisplaySize(i);int nullable = metaData.isNullable(i);String columnTypeName = metaData.getColumnTypeName(i);String columnClassName = metaData.getColumnClassName(i);LOG.info("Column Name: {}", columnName);LOG.info("Data Type: {}", columnType);LOG.info("Column Length: {}", columnLength);LOG.info("Column Nullable: {}", nullable);LOG.info("Column typeName: {}", columnTypeName);LOG.info("Column Class Name: {}", columnClassName);LOG.info("------------------------");}// 处理查询结果while (resultSet.next()) {// 获取数据并进行处理for (int i = 1; i <= columnCount; i++) {Object obj = resultSet.getObject(i);LOG.info("Column {} : {}", i, obj);}LOG.info("------------------------");}}
}