commit
e8e15a0d5e
@ -646,7 +646,7 @@ public class ExtractDataService {
|
|||||||
JdbcProvider jdbcProvider = CommonBeanFactory.getBean(JdbcProvider.class);
|
JdbcProvider jdbcProvider = CommonBeanFactory.getBean(JdbcProvider.class);
|
||||||
DatasourceRequest datasourceRequest = new DatasourceRequest();
|
DatasourceRequest datasourceRequest = new DatasourceRequest();
|
||||||
datasourceRequest.setDatasource(engine);
|
datasourceRequest.setDatasource(engine);
|
||||||
datasourceRequest.setQuery("mysql> SELECT VERSION();");
|
datasourceRequest.setQuery("SELECT VERSION()");
|
||||||
String version = jdbcProvider.getData(datasourceRequest).get(0)[0];
|
String version = jdbcProvider.getData(datasourceRequest).get(0)[0];
|
||||||
DDLProvider ddlProvider = ProviderFactory.getDDLProvider(engine.getType());
|
DDLProvider ddlProvider = ProviderFactory.getDDLProvider(engine.getType());
|
||||||
datasourceRequest.setQuery(ddlProvider.createTableSql(tableName, datasetTableFields, engine, version));
|
datasourceRequest.setQuery(ddlProvider.createTableSql(tableName, datasetTableFields, engine, version));
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user