您的位置:首页 > 产品设计 > UI/UE

利用dbcp数据库连接池连接数据库,并利用dbtuils框架对数据库test中book表进行插入、删除、修改、查询的操作代码

2012-11-28 21:15 1216 查看
package com.csdn.hbsi.utils;

import java.io.InputStream;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSourceFactory;

public class DBManager_dbcp {

private static DataSource ds;

static {

try {

InputStream in = DBManager.class.getClassLoader()

.getResourceAsStream("dbcp.properties");

Properties prop = new Properties();

prop.load(in);

ds = BasicDataSourceFactory.createDataSource(prop);

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public static Connection getConnection() throws Exception {

return ds.getConnection();

}

public static void closeDB(Connection conn,Statement st,ResultSet rs){

if(conn!=null){

try {

conn.close();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

}

package com.csdn.hbsi.demo;

import java.sql.SQLException;

import org.apache.commons.dbutils.QueryRunner;

import org.junit.Test;

import com.csdn.hbsi.utils.DBManager;

public class crud {

@Test

public void insert() throws SQLException {

QueryRunner runner = new QueryRunner(DBManager.getDataSource());

String sql = "insert into book(id,name,price,author,description) values(?,?,?,?,?)";

Object params[] = { 3, "cc", "cc", "cc@cc", "1998-01-01" };

runner.update(sql, params);

}

}

package com.csdn.hbsi.Demo;

import java.sql.SQLException;

import java.util.List;

import javax.xml.registry.infomodel.User;

import org.apache.commons.dbutils.QueryRunner;

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

import com.csdn.hbsi.utils.DBManager;

public class crud {

public void insert() throws SQLException {

QueryRunner runner = new QueryRunner();

String sql = "insert into book(id,name,price,author,description) values(?,?,?,?,?)";

Object params[] = { 3, "cc", "cc", "cc@cc", "1998-01-01" };

runner.update(sql, params);

}

public void update() throws SQLException {

QueryRunner runner = new QueryRunner();

String sql = "update bookset name=? where id=?";

Object params[] = { 3, "bb"};

runner.update(sql, params);

}

public void delete() throws SQLException {

QueryRunner runner = new QueryRunner();

String sql = "delete from book where id=?";

Object params[] = { 3};

runner.update(sql, params);

}

public void find() throws SQLException {

QueryRunner runner = new QueryRunner();

String sql = "select * from book";

List list=(List) runner.query(sql, new BeanListHandler(User.class));

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

}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐