Skip to content

Commit 0fe586d

Browse files
committed
feat:support Serializable
1 parent 3ae6f88 commit 0fe586d

33 files changed

Lines changed: 207 additions & 239 deletions

File tree

chat2db-client/src/components/ConnectionEdit/config/dataSource.ts

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -250,6 +250,10 @@ export const dataSourceFormConfigs: IConnectionConfig[] = [
250250
{
251251
"key": "zeroDateTimeBehavior",
252252
"value": "convertToNull"
253+
},
254+
{
255+
"key": "useInformationSchema",
256+
"value": "true"
253257
}
254258
],
255259
type: DatabaseTypeCode.MYSQL,

chat2db-server/chat2db-plugins/chat2db-clickhouse/src/main/java/ai/chat2db/plugin/clickhouse/builder/ClickHouseSqlBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
import org.apache.commons.lang3.StringUtils;
1212

1313

14-
public class ClickHouseSqlBuilder extends DefaultSqlBuilder implements SqlBuilder {
14+
public class ClickHouseSqlBuilder extends DefaultSqlBuilder {
1515
@Override
1616
public String buildCreateTableSql(Table table) {
1717
StringBuilder script = new StringBuilder();

chat2db-server/chat2db-plugins/chat2db-h2/src/main/java/ai/chat2db/plugin/h2/builder/H2SqlBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import ai.chat2db.spi.model.Schema;
66
import org.apache.commons.lang3.StringUtils;
77

8-
public class H2SqlBuilder extends DefaultSqlBuilder implements SqlBuilder {
8+
public class H2SqlBuilder extends DefaultSqlBuilder {
99

1010
@Override
1111
public String buildCreateSchemaSql(Schema schema) {

chat2db-server/chat2db-plugins/chat2db-kingbase/src/main/java/ai/chat2db/plugin/kingbase/builder/KingBaseSqlBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import java.util.stream.Collectors;
1515

1616

17-
public class KingBaseSqlBuilder extends DefaultSqlBuilder implements SqlBuilder {
17+
public class KingBaseSqlBuilder extends DefaultSqlBuilder {
1818
@Override
1919
public String buildCreateTableSql(Table table) {
2020
StringBuilder script = new StringBuilder();
Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
package ai.chat2db.plugin.mongodb;
2+
3+
import ai.chat2db.spi.model.Command;
4+
import ai.chat2db.spi.model.ExecuteResult;
5+
import ai.chat2db.spi.sql.SQLExecutor;
6+
7+
import java.util.List;
8+
9+
public class MongodbCommandExecutor extends SQLExecutor {
10+
11+
@Override
12+
public List<ExecuteResult> executeSelectTable(Command command) {
13+
String sql = "db." + command.getTableName() + ".find()";
14+
command.setScript(sql);
15+
return execute(command);
16+
}
17+
}

chat2db-server/chat2db-plugins/chat2db-mongodb/src/main/java/ai/chat2db/plugin/mongodb/MongodbMetaData.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
package ai.chat2db.plugin.mongodb;
22

3+
import ai.chat2db.spi.CommandExecutor;
34
import ai.chat2db.spi.MetaData;
45
import ai.chat2db.spi.jdbc.DefaultMetaService;
56
import ai.chat2db.spi.model.Database;
6-
import ai.chat2db.spi.sql.SQLExecutor;
77
import com.google.common.collect.Lists;
88

99
import java.sql.Connection;
@@ -17,4 +17,9 @@ public class MongodbMetaData extends DefaultMetaService implements MetaData {
1717
public List<Database> databases(Connection connection) {
1818
return Lists.newArrayList();
1919
}
20+
21+
@Override
22+
public CommandExecutor getCommandExecutor() {
23+
return new MongodbCommandExecutor();
24+
}
2025
}

chat2db-server/chat2db-plugins/chat2db-mysql/src/main/java/ai/chat2db/plugin/mysql/builder/MysqlSqlBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import java.util.*;
1515

1616

17-
public class MysqlSqlBuilder extends DefaultSqlBuilder implements SqlBuilder {
17+
public class MysqlSqlBuilder extends DefaultSqlBuilder {
1818
@Override
1919
public String buildCreateTableSql(Table table) {
2020
StringBuilder script = new StringBuilder();

chat2db-server/chat2db-plugins/chat2db-oracle/src/main/java/ai/chat2db/plugin/oracle/builder/OracleSqlBuilder.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,14 +2,13 @@
22

33
import ai.chat2db.plugin.oracle.type.OracleColumnTypeEnum;
44
import ai.chat2db.plugin.oracle.type.OracleIndexTypeEnum;
5-
import ai.chat2db.spi.SqlBuilder;
65
import ai.chat2db.spi.jdbc.DefaultSqlBuilder;
76
import ai.chat2db.spi.model.Table;
87
import ai.chat2db.spi.model.TableColumn;
98
import ai.chat2db.spi.model.TableIndex;
109
import org.apache.commons.lang3.StringUtils;
1110

12-
public class OracleSqlBuilder extends DefaultSqlBuilder implements SqlBuilder {
11+
public class OracleSqlBuilder extends DefaultSqlBuilder {
1312
@Override
1413
public String buildCreateTableSql(Table table) {
1514
StringBuilder script = new StringBuilder();

chat2db-server/chat2db-plugins/chat2db-postgresql/src/main/java/ai/chat2db/plugin/postgresql/builder/PostgreSQLSqlBuilder.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import ai.chat2db.plugin.postgresql.type.PostgreSQLColumnTypeEnum;
44
import ai.chat2db.plugin.postgresql.type.PostgreSQLIndexTypeEnum;
5-
import ai.chat2db.spi.SqlBuilder;
65
import ai.chat2db.spi.jdbc.DefaultSqlBuilder;
76
import ai.chat2db.spi.model.*;
87
import org.apache.commons.collections4.CollectionUtils;
@@ -14,7 +13,7 @@
1413
import java.util.stream.Collectors;
1514

1615

17-
public class PostgreSQLSqlBuilder extends DefaultSqlBuilder implements SqlBuilder {
16+
public class PostgreSQLSqlBuilder extends DefaultSqlBuilder {
1817
@Override
1918
public String buildCreateTableSql(Table table) {
2019
StringBuilder script = new StringBuilder();

chat2db-server/chat2db-plugins/chat2db-redis/pom.xml

Lines changed: 0 additions & 34 deletions
This file was deleted.

0 commit comments

Comments
 (0)