Browse Source

添加 each 方法

James 5 years ago
parent
commit
3e2a21bbda

+ 7 - 0
src/main/java/com/jfinal/plugin/activerecord/DaoTemplate.java

@@ -18,6 +18,7 @@ package com.jfinal.plugin.activerecord;
 
 import java.util.List;
 import java.util.Map;
+import java.util.function.Function;
 
 /**
  * DaoTemplate
@@ -71,6 +72,12 @@ public class DaoTemplate<M extends Model> {
 	
 	// ---------
 	
+	public void each(Function<Model, Boolean> func) {
+		dao.each(func, sqlPara.getSql(), sqlPara.getPara());
+	}
+	
+	// ---------
+	
 	public List<M> findByCache(String cacheName, Object key) {
 		return dao.findByCache(cacheName, key, sqlPara.getSql(), sqlPara.getPara());
 	}

+ 7 - 0
src/main/java/com/jfinal/plugin/activerecord/DbTemplate.java

@@ -22,6 +22,7 @@ import java.sql.Timestamp;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
+import java.util.function.Function;
 
 /**
  * DbTemplate
@@ -86,6 +87,12 @@ public class DbTemplate {
 	
 	// ---------
 	
+	public void each(Function<Record, Boolean> func) {
+		db.each(func, sqlPara.getSql(), sqlPara.getPara());
+	}
+	
+	// ---------
+	
 	public int delete() {
 		return db.delete(sqlPara.getSql(), sqlPara.getPara());
 	}