opensource/Chat2DB
1
0
Fork 0
mirror of https://github.com/CodePhiliaX/Chat2DB.git synced 2025-08-02 13:34:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1223 from openai0229/fix-mysql-view-ddl-query

Browse Source 
fix-mysql-view-ddl-query
This commit is contained in:
ji
2024-03-15 13:39:01 +08:00
committed by GitHub
parent 9e8a87725e 73cd1908ca
commit f6ad1ac33f
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
chat2db-server/chat2db-plugins/chat2db-mysql/src/main/java/ai/chat2db/plugin/mysql/MysqlMetaData.java
View File

@ -214,21 +214,18 @@ public class MysqlMetaData extends DefaultMetaService implements MetaData {
} }
} }
private static String VIEW_DDL_SQL="show create view %s";
private static String VIEW_SQL
= "SELECT TABLE_SCHEMA AS DatabaseName, TABLE_NAME AS ViewName, VIEW_DEFINITION AS definition, CHECK_OPTION, "
+ "IS_UPDATABLE FROM INFORMATION_SCHEMA.VIEWS WHERE TABLE_SCHEMA = '%s' AND TABLE_NAME = '%s';";
@Override @Override
public Table view(Connection connection, String databaseName, String schemaName, String viewName) { public Table view(Connection connection, String databaseName, String schemaName, String viewName) {
String sql = String.format(VIEW_SQL, databaseName, viewName); String sql = String.format(VIEW_DDL_SQL, viewName);
return SQLExecutor.getInstance().execute(connection, sql, resultSet -> { return SQLExecutor.getInstance().execute(connection, sql, resultSet -> {
Table table = new Table(); Table table = new Table();
table.setDatabaseName(databaseName); table.setDatabaseName(databaseName);
table.setSchemaName(schemaName); table.setSchemaName(schemaName);
table.setName(viewName); table.setName(viewName);
if (resultSet.next()) { if (resultSet.next()) {
table.setDdl(resultSet.getString("definition")); table.setDdl(resultSet.getString("Create View"));
} }
return table; return table;
}); });