This commit is contained in:
地平线
2015-06-01 15:07:47 +08:00
parent ff36fb9a82
commit 1dfb1ee0ac

View File

@@ -417,7 +417,7 @@ public final class DataJDBCSource implements DataSource {
for (final Class t : info.distributeTables) {
EntityInfo<T> infox = loadEntityInfo(t);
stmt = conn.createStatement();
rs = stmt.executeQuery("SELECT MAX(" + infox.getPrimarySQLColumn() + ") FROM " + infox.getTable());
rs = stmt.executeQuery("SELECT MAX(" + info.getPrimarySQLColumn() + ") FROM " + infox.getTable());// 必须是同一字段名
if (rs.next()) {
if (primaryType == int.class) {
int v = rs.getInt(1) / info.allocationSize;