用c3p0实现Apache—DBUtils框架的Dao层源码
用c3p0实现Apache—DBUtils框架的Dao层源码分类： 课堂随笔 2011-11-22 20:43 484人阅读 评论(0) 收藏 举报
用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();
}
页:
[1]