lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

DataJdbcSource读操作不自动建表

Browse Source
This commit is contained in:
redkale
2023-02-01 14:37:39 +08:00
parent 8088197e29
commit 44f0fe1852
1 changed files with 9 additions and 129 deletions
Download Patch File Download Diff File Expand all files Collapse all files

138
src/main/java/org/redkale/source/DataJdbcSource.java
View File

@@ -1344,22 +1344,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
map.clear(); map.clear();
if (isTableNotExist(info, e.getSQLState())) { if (isTableNotExist(info, e.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return map; return map;
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -1455,22 +1440,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
} catch (SQLException e) { } catch (SQLException e) {
if (isTableNotExist(info, e.getSQLState())) { if (isTableNotExist(info, e.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return defVal; return defVal;
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -1560,22 +1530,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
rs.clear(); rs.clear();
if (isTableNotExist(info, e.getSQLState())) { if (isTableNotExist(info, e.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return rs; return rs;
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -1678,22 +1633,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
rs.clear(); rs.clear();
if (isTableNotExist(info, e.getSQLState())) { if (isTableNotExist(info, e.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return rs; return rs;
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -1776,22 +1716,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
} catch (SQLException e) { } catch (SQLException e) {
if (isTableNotExist(info, e.getSQLState())) { if (isTableNotExist(info, e.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return null; return null;
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -1875,22 +1800,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
} catch (SQLException e) { } catch (SQLException e) {
if (isTableNotExist(info, e.getSQLState())) { if (isTableNotExist(info, e.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return defValue; return defValue;
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -1975,22 +1885,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
} catch (SQLException e) { } catch (SQLException e) {
if (isTableNotExist(info, e.getSQLState())) { if (isTableNotExist(info, e.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return false; return false;
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -2074,22 +1969,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
} catch (SQLException se) { } catch (SQLException se) {
if (isTableNotExist(info, se.getSQLState())) { if (isTableNotExist(info, se.getSQLState())) {
if (info.getTableStrategy() == null) { if (info.getTableStrategy() == null) {
String[] tableSqls = createTableSqls(info); //读操作不自动创建表，可能存在读写分离
if (tableSqls != null) {
try {
Statement st = conn.createStatement();
if (tableSqls.length == 1) {
st.execute(tableSqls[0]);
} else {
for (String tableSql : tableSqls) {
st.addBatch(tableSql);
}
st.executeBatch();
}
st.close();
} catch (SQLException e2) {
}
}
return new Sheet<>(0, new ArrayList()); return new Sheet<>(0, new ArrayList());
} else if (tables != null && tables.length == 1) { } else if (tables != null && tables.length == 1) {
//只查一个不存在的分表 //只查一个不存在的分表
@@ -2261,7 +2141,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
} }
protected List<String> checkNotExistTables(Connection conn, String[] tables) throws SQLException { //, String firstNotExistTable protected List<String> checkNotExistTables(Connection conn, String[] tables) throws SQLException { //, String firstNotExistTable
// 数据库不一定要按批量提交的SQL顺序执行， 所以第一个不存在的表不一定再tables的第一位, // 数据库不一定要按批量提交的SQL顺序执行， 所以第一个不存在的表不一定在tables的第一位,
// 比如 DELETE FROM table1; DELETE FROM table2; 如果table1、table2都不存在，SQL可能会抛出table2不存在的异常 // 比如 DELETE FROM table1; DELETE FROM table2; 如果table1、table2都不存在，SQL可能会抛出table2不存在的异常
// List<String> maybeNoTables = new ArrayList<>(); // List<String> maybeNoTables = new ArrayList<>();
// String minTableName = (firstNotExistTable.indexOf('.') > 0) ? firstNotExistTable.substring(firstNotExistTable.indexOf('.') + 1) : null; // String minTableName = (firstNotExistTable.indexOf('.') > 0) ? firstNotExistTable.substring(firstNotExistTable.indexOf('.') + 1) : null;