基于Spring jdbcTemple做的泛型DAO

1、基于spring jdbctemple做的泛型dao采纳java的反射机制和spring jdbctemplate完成的泛型dao public interface basedao t, pk tends serializable * a one record fution * param entity * description: public int add(t entity); * add multi record function * param entitycollection * description: public int addlist(collection t entity

2、collection, class t entityclazz); * delete one record function * param entity * description: public int delete(t entity); * delete one record by * param entityclass * param id * description: public int deletebyid(class t entityclass, pk id); * delete many record function * param entitycollection * p

3、aram entityclazz * description: public int deletelist(collection t entitycollection, class t entityclazz); * up the record * param entity * description: public int update(t entity); * update many records meanwhile * param entitycollection * param entityclazz * description: public int updatelist(coll

4、ection t entitycollection, class t entityclazz); * query all record list * param entityclazz * return * description: public list t all(class t entityclazz); * find one special record * return * description: public t findbyid(class t entityclass, pk id); repository("basedao") public class b

5、asedaoimpl t, pk extends serializable extends simpledaosupport implements basedao t, pk private final sing table_prefix = "pub_" * return * description: protect simplejdbcinsert getsimplejdbcinsert() return new simplejdbcinsert(this.getjdbctemplate(); * (non-javadoc) * see com.morningstar.

6、planning.dao.basedaoadd(java.lang.class) override public int add(t entity) string tablename = this.table_prefix + entity.getclass().getsimplename(); simplejdbcinsert insertactor = getsimplejdbcinsert(); insertactor.tablename(tablename.tolowercase(); return insertactor.exee(new beanpropertysqlparamet

7、ersource(entity); * (non-javadoc) * see com.morningstar.planning.dao.basedaoaddall(java.util.collection) override public int addlist(collection t entitycollection, class t entityclazz) string tablename = this.table_prefix + entityclazz.getsimplename(); simplejdbcinsert insertactor = getsimplejdbcins

8、ert(); sqlparametersource batchargs = sqlparametersourceuti.createbatch(entitycollection.toarray(); insertactor.settablename(tablename.tolowercase(); int relt = insertactor.executebatch(batchargs); return result.length; * (non-javadoc) * see com.morningstar.planning.dao.basedaodelete(java.lang.objec

9、t) override public int delete(t entity) string tablename = this.table_prefix + entity.getclass().getsimplename(); string sql = "delete from " + tablename + " where id =:id" return this.getsimplejdbctemplate().update(sql, new beanpropertysqlparametersource(entity); * (non-javadoc)

10、 * see com.morningstar.planning.dao.basedaodeletebyid(java.lang.class, * java.io.serializable) override public int deletebyid(class t entityclazz, pk id) string tablename = this.table_prefix + entityclazz.getsimplename(); string sql = "delete from " + tablename + " where id=?" re

11、turn this.getsimplejdbctemplate().update(sql, id); * (non-javadoc) * see * com.morningstar.planning.dao.basedaodeletelist(java.util.collection, * java.lang.class) override public int deletelist(collection t entitycollection, class t entityclazz) string tablename = this.table_prefix + entityclazz.get

12、simplename(); string sql = "delete from " + tablename + " where id=:id" sqlparametersource batchargs = sqlparametersourceutils.createbatch(entitycollection.toarray(); int result = this.getsimplejdbctemplate().batchupdate(sql, batchargs); return result.length; * (non-javadoc) * se

13、e com.morningstar.planning.dao.basedaoupdate(java.lang.object) override suppresswarnings("rawtypes") public int update(t entity) string tablename = this.table_prefix + entity.getclass().getsimplename(); stringbuffer sql = new stringbuffer("update " + tablename + " set "

14、); field fields = entity.getclass().getdeclaredfields(); for (int i = 0; i fields.length; i+) field fied = fieldsi; string fiedname = fied.getname(); class fiedtype = fied.gettype(); if (!fiedname.equalsignorecase("id") !fiedtype.equals(collections.class) !fiedtype.equals(map.class) !fiedt

15、ype.equals(list.class) !fiedtype.equals(set.class) sql.append(fiedname + " = :" + fiedname + ","); sql.replace(sql.lastindexof(","), sql.length(), ""); sql.append(" where id = :id"); sqlparametersource ps = new beanpropertysqlparametersource(entity);

16、 return this.getsimplejdbctemplate().update(sql.tostring(), ps); * (non-javadoc) * see * com.morningstar.planning.dao.basedaoupdatelist(java.util.collection, * java.lang.class) override suppresswarnings("rawtypes") public int updatelist(collection t entitycollection, class t entityclazz) s

17、tring tablename = this.table_prefix + entityclazz.getsimplename(); stringbuffer sql = new stringbuffer("update " + tablename + " set "); field fields = entityclazz.getdeclaredfields(); for (int i = 0; i fields.length; i+) field fied = fieldsi; string fiedname = fied.getname(); cl

18、ass fiedtype = fied.gettype(); if (!fiedname.equalsignorecase("id") !fiedtype.equals(collections.class) !fiedtype.equals(map.class) !fiedtype.equals(list.class) !fiedtype.equals(set.class) sql.append(fiedname + " = :" + fiedname + ","); sql.replace(sql.lastindexof("

19、;,"), sql.length(), ""); sql.append(" where id = :id"); sqlparametersource batchargs = sqlparametersourceutils.createbatch(entitycollection.toarray(); int result = this.getsimplejdbctemplate().batchupdate(sql.tostring(), batchargs); return result.length; * (non-javadoc) * se

20、e com.morningstar.planning.dao.basedaofindall(java.lang.class) override public list t findall(class t entityclazz) string tablename = this.table_prefix + entityclazz.getsimplename(); string sql = "select * from " + tablename; return this.getsimplejdbctemplate().query(sql, beanpropertyrowmapper.newinstance(entityclazz); * (non-javadoc) * see com.morningstar.planning.dao.basedaofindbyid(java.lang.class, * java.io.serializable) override