davinci数据源定义

 

连接数据库

1，获取数据源----配置用相应的数据源类生成数据源---大部分的数据源支持jdbc,所以可以包装成jdbc的数据源，然后连接（获取到了数据源就可以进行一切数据库操作）

2，根据数据源获取连接，从而可以连接数据库

 

SourceController

SourceUtils

   getDataSource 这里拓展数据源

 

  dataSource = getDataSource(jdbcUrl, username, password, database, version, isExt);

                connection = dataSource.getConnection();

 

   DataSource getDataSource(String jdbcUrl, String userename, String password, String database, String version, boolean isExt) throws SourceException {

        if (jdbcUrl.toLowerCase().contains(DataTypeEnum.ELASTICSEARCH.getDesc().toLowerCase())) {

            return ESDataSource.getDataSource(jdbcUrl, userename, password, jdbcDataSource);

        } else {

            return jdbcDataSource.getDataSource(jdbcUrl, userename, password, database, version, isExt);

        }

    }

 

 

 

  connection.setAutoCommit(false);

                pstmt = connection.prepareStatement(sql);

 

 

 public synchronized void removeDatasource(String jdbcUrl, String username, String password, String version, boolean isExt) {

        String key = SourceUtils.getKey(jdbcUrl, username, password, version, isExt);

 

        if (dataSourceMap.containsKey(key)) {

            DruidDataSource druidDataSource = dataSourceMap.get(key);

            druidDataSource.close();

            dataSourceMap.remove(key);

        }

    }

 

 

 

获取到了数据源就可以进行一切数据库操作

 

 

/**

     * 判断表是否存在

     *

     * @param tableName

     * @return

     * @throws SourceException

     */

    public boolean tableIsExist(String tableName) throws SourceException {

        boolean result = false;

        Connection connection = null;

        try {

            connection = sourceUtils.getConnection(this.jdbcUrl, this.username, this.password, this.database, this.dbVersion, this.isExt);

            if (null != connection) {

                ResultSet tables = connection.getMetaData().getTables(null, null, tableName, null);

                if (null != tables && tables.next()) {

                    result = true;

                } else {

                    result = false;

                }

                tables.close();

            }

        } catch (Exception e) {

            throw new SourceException("Get connection meta data error, jdbcUrl=" + this.jdbcUrl);

        } finally {

            sourceUtils.releaseConnection(connection);

        }

 

        return result;

    }