diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java index 75b244adc..437ee5ac9 100644 --- a/src/org/redkale/source/DataJdbcSource.java +++ b/src/org/redkale/source/DataJdbcSource.java @@ -247,7 +247,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC if (values.length == 0) return; try { if (!info.isVirtualEntity()) { - final String sql = info.getInsertSQL(values[0]); + final String sql = info.getInsertPrepareSQL(values[0]); final Class primaryType = info.getPrimary().type(); final Attribute primary = info.getPrimary(); Attribute[] attrs = info.insertAttributes; @@ -623,7 +623,7 @@ public class DataJdbcSource extends AbstractService implements DataSource, DataC Class clazz = info.getType(); int c = -1; if (!info.isVirtualEntity()) { - final String updateSQL = info.getUpdateSQL(values[0]); + final String updateSQL = info.getUpdatePrepareSQL(values[0]); final Attribute primary = info.getPrimary(); conn.setReadOnly(false); final PreparedStatement prestmt = conn.prepareStatement(updateSQL); diff --git a/src/org/redkale/source/EntityInfo.java b/src/org/redkale/source/EntityInfo.java index 7cb680804..0779eeba6 100644 --- a/src/org/redkale/source/EntityInfo.java +++ b/src/org/redkale/source/EntityInfo.java @@ -91,25 +91,25 @@ public final class EntityInfo { final DistributeTableStrategy tableStrategy; //根据主键查找单个对象的SQL, 含 ? - final String querySQL; + final String queryPrepareSQL; //数据库中所有字段 private final Attribute[] queryAttributes; //新增SQL, 含 ?,即排除了自增长主键和标记为@Column(insertable=false)的字段 - private final String insertSQL; + private final String insertPrepareSQL; //数据库中所有可新增字段 final Attribute[] insertAttributes; //根据主键更新所有可更新字段的SQL,含 ? - private final String updateSQL; + private final String updatePrepareSQL; //数据库中所有可更新字段 final Attribute[] updateAttributes; //根据主键删除记录的SQL,含 ? - private final String deleteSQL; + private final String deletePrepareSQL; //日志级别,从LogLevel获取 private final int logLevel; @@ -319,20 +319,20 @@ public final class EntityInfo { if (insertsb2.length() > 0) insertsb2.append(','); insertsb2.append('?'); } - this.insertSQL = "INSERT INTO " + (this.tableStrategy == null ? table : "${newtable}") + "(" + insertsb + ") VALUES(" + insertsb2 + ")"; + this.insertPrepareSQL = "INSERT INTO " + (this.tableStrategy == null ? table : "${newtable}") + "(" + insertsb + ") VALUES(" + insertsb2 + ")"; StringBuilder updatesb = new StringBuilder(); for (String col : updatecols) { if (updatesb.length() > 0) updatesb.append(", "); updatesb.append(col).append(" = ?"); } - this.updateSQL = "UPDATE " + (this.tableStrategy == null ? table : "${newtable}") + " SET " + updatesb + " WHERE " + getPrimarySQLColumn(null) + " = ?"; - this.deleteSQL = "DELETE FROM " + (this.tableStrategy == null ? table : "${newtable}") + " WHERE " + getPrimarySQLColumn(null) + " = ?"; - this.querySQL = "SELECT * FROM " + table + " WHERE " + getPrimarySQLColumn(null) + " = ?"; + this.updatePrepareSQL = "UPDATE " + (this.tableStrategy == null ? table : "${newtable}") + " SET " + updatesb + " WHERE " + getPrimarySQLColumn(null) + " = ?"; + this.deletePrepareSQL = "DELETE FROM " + (this.tableStrategy == null ? table : "${newtable}") + " WHERE " + getPrimarySQLColumn(null) + " = ?"; + this.queryPrepareSQL = "SELECT * FROM " + table + " WHERE " + getPrimarySQLColumn(null) + " = ?"; } else { - this.insertSQL = null; - this.updateSQL = null; - this.deleteSQL = null; - this.querySQL = null; + this.insertPrepareSQL = null; + this.updatePrepareSQL = null; + this.deletePrepareSQL = null; + this.queryPrepareSQL = null; } this.autoGenerated = auto; this.autouuid = uuid; @@ -412,9 +412,9 @@ public final class EntityInfo { * * @return String */ - public String getInsertSQL(T bean) { - if (this.tableStrategy == null) return insertSQL; - return insertSQL.replace("${newtable}", getTable(bean)); + public String getInsertPrepareSQL(T bean) { + if (this.tableStrategy == null) return insertPrepareSQL; + return insertPrepareSQL.replace("${newtable}", getTable(bean)); } /** @@ -424,9 +424,9 @@ public final class EntityInfo { * * @return String */ - public String getUpdateSQL(T bean) { - if (this.tableStrategy == null) return updateSQL; - return updateSQL.replace("${newtable}", getTable(bean)); + public String getUpdatePrepareSQL(T bean) { + if (this.tableStrategy == null) return updatePrepareSQL; + return updatePrepareSQL.replace("${newtable}", getTable(bean)); } /** @@ -436,9 +436,9 @@ public final class EntityInfo { * * @return String */ - public String getDeleteSQL(T bean) { - if (this.tableStrategy == null) return deleteSQL; - return deleteSQL.replace("${newtable}", getTable(bean)); + public String getDeletePrepareSQL(T bean) { + if (this.tableStrategy == null) return deletePrepareSQL; + return deletePrepareSQL.replace("${newtable}", getTable(bean)); } /**