Browse Source

update、save方法添加 /**

James 4 years ago
parent
commit
a06915dacd
1 changed files with 11 additions and 1 deletions
  1. 11 1
      src/main/java/com/jfinal/plugin/activerecord/DbPro.java

+ 11 - 1
src/main/java/com/jfinal/plugin/activerecord/DbPro.java

@@ -691,6 +691,7 @@ public class DbPro {
 			config.dialect.fillStatement(pst, paras);
 			int result = pst.executeUpdate();
 			config.dialect.getRecordGeneratedKey(pst, record, pKeys);
+			record.clearModifyFlag();
 			return result >= 1;
 		}
 	}
@@ -727,6 +728,10 @@ public class DbPro {
 	}
 	
 	protected boolean update(Config config, Connection conn, String tableName, String primaryKey, Record record) throws SQLException {
+		if (record.modifyFlag == null || record.modifyFlag.isEmpty()) {
+			return false;
+		}
+		
 		String[] pKeys = primaryKey.split(",");
 		Object[] ids = new Object[pKeys.length];
 		
@@ -744,7 +749,12 @@ public class DbPro {
 			return false;
 		}
 		
-		return update(config, conn, sql.toString(), paras.toArray()) >= 1;
+		int result = update(config, conn, sql.toString(), paras.toArray());
+		if (result >= 1) {
+			record.clearModifyFlag();
+			return true;
+		}
+		return false;
 	}
 	
 	/**