DbTestConfigFactory.java 文件源码

/**
 * create  a query builder instance per db type
 *
 * @return query builder instance
 */
@Bean(name = "queryBuilder", autowire = Autowire.BY_TYPE)
public IQueryBuilder createSqlBuilder() throws SQLException {
    JdbcHelper jdbcHelper = beanFactory.getBean(JdbcHelper.class);
    StorageProperties storageProperties = beanFactory.getBean(StorageProperties.class);
    String productName = storageProperties.getDbType().toString();
    Connection connection = jdbcHelper.getDataSource().getConnection();
    connection.close();
    IQueryBuilder queryBuilder;
    switch (productName) {
        case "oracle":
            queryBuilder = new OracleQueryBuilder();
            break;
        case "mssql":
            queryBuilder = new SqlServerQueryBuilder();
            break;
        case "derby":
            queryBuilder = new DerbyQueryBuilder();
            break;
        case "postgresql":
            queryBuilder = new PostgresqlQueryBuilder();
            break;
        case "mysql":
            queryBuilder = new MysqlQueryBuilder();
            break;
        default:
            queryBuilder = new DerbyQueryBuilder();
            break;
    }
    return queryBuilder;
}