用c3p0实现Apache—DBUtils框架的Dao层源码

用c3p0实现Apache—DBUtils框架的Dao层源码

用c3p0实现Apache—DBUtils框架的Dao层源码

import java.sql.SQLException;


import java.util.Arrays;


import java.util.List;


import java.util.Map;




import org.apache.commons.dbutils.QueryRunner;


import org.apache.commons.dbutils.handlers.ArrayHandler;


import org.apache.commons.dbutils.handlers.ArrayListHandler;


import org.apache.commons.dbutils.handlers.BeanHandler;


import org.apache.commons.dbutils.handlers.BeanListHandler;


import org.apache.commons.dbutils.handlers.MapListHandler;




import com.hbsi.domain.User;


import com.hbsi.utils.DBManager_c3p0;




public class UserDaoImpl {


 // 插入操作


 public void insert() {


 // 得到数据库连接池对象


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "insertinto users(name,password) values('liop','8988')";


 try {


 runner.update(sql);


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }


 }




 // 删除操作


 public void delete() {


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "deletefrom users where id=1";


 try {


 runner.update(sql);


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }


 }




 // 更新操作


 public void update() {


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "updateusers set name='老王',password=222 where id=3";


 try {


 runner.update(sql);


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }


 }




 // 通过Id查询操作


 public void findById() {


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "select* from users where id=3";


 BeanHandler rsh = newBeanHandler(User.class);


 try {


 User user =runner.query(sql, rsh);


 System.out.println(user.toString());


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }


 }




 // 查询所有


 public void findAll() {


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "select* from users";


 BeanListHandler rsh = newBeanListHandler(User.class);




 try {


 List<User>entities = runner.query(sql, rsh);


 System.out.println(entities.size());


 for (User entity :entities) {


 System.out.println(entity.toString());


 }


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }


 }




 // 批处理


 public void bath() {


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "insertinto users(name,password) values(?,?)";


 Object[][] params = { {"aaa", "111" }, { "qqq", "222" },


 {"www", "333" }, { "eee", "444" } };


 try {


 runner.batch(sql,params);


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }


 }




 // ArrayHandler的使用


 public void testArrayHandler(){


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "select* from users where id=5";


 ArrayHandler rsh = newArrayHandler();


 try {


 Object[] array =runner.query(sql, rsh);


 System.out.println(Arrays.asList(array));


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }


 }




 // ArrayListHandler的使用


 public void testArrayListHandler(){


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "select* from users";


 ArrayListHandler rsh =new ArrayListHandler();


 try {


 List<Object[]>array = runner.query(sql, rsh);


 for (int i = 1; i< array.size(); i++) {


 System.out.println(Arrays.asList(array.get(i)));


 }


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }




 }




 // Map的应用


 public voidtestMapListHandler(){


 QueryRunner runner = newQueryRunner(DBManager_c3p0.getDataSource());


 String sql = "select* from users";


 MapListHandler rsh = newMapListHandler();


 List<Map<String,Object>> result=null;


 try {


 result =(List<Map<String, Object>>) runner.query(sql,rsh);


 for (int i = 0; i< result.size(); i++) {


 Map<String,Object> map = result.get(i);


 System.out.println("---------------------");




 for(Map.Entry<String, Object> me : map.entrySet()) {


 StringcolName = me.getKey();


 Objectvalue = me.getValue();




 System.out.println(colName+ " = " + value);


 }


 }


 } catch (SQLException e){


 // TODOAuto-generated catch block


 e.printStackTrace();


 }




 }




 public static voidmain(String[] args) {


 // new UserDaoImpl().insert();


 // newUserDaoImpl().delete();


 // newUserDaoImpl().update();


 // newUserDaoImpl().findById();


 // newUserDaoImpl().findAll();


 // 批处理


 // newUserDaoImpl().bath();


 // 数组使用


 // newUserDaoImpl().testArrayHandler();


 //


 //newUserDaoImpl().testArrayListHandler();


 newUserDaoImpl().testMapListHandler();


 }