利用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());
}
}
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());
}
}
相关文章推荐
- 利用dbcp数据库连接池连接数据库,并利用dbtuils框架对数据库test中book表进行插入、删除、修改、查询的操作。book表结构如下:(id,name,price,author,descrip
- 利用dbcp数据库连接池连接数据库,并利用dbtuils框架对数据库test中book表进行插入、删除、修改、查询的操作。
- vb 利用ADO.Net实现数据库的连接,修改,删除,插入操作
- JDBC 数据库连接 创建表格、插入、查询、删除、修改数据 基本操作
- tuxedo服务里面对数据库进行了插入,修改删除等操作而没有COMMIT或ROLLBACK
- SpringBoot入门-6(利用jpa连接hibernate,并进行生成表,对表的增加,删除,查询操作)
- Delphi-ADOQuery连接数据库的查询、插入、删除、修改
- Delphi ADOQuery连接数据库的查询、插入、删除、修改
- JAVA对数据库进行操作,实现数据库中数据的插入,查询,更改,删除操作
- 在MyEclipse中利用Hibernate框架完成数据库的基本操作(查询、更新、删除)
- Java连接HBASE数据库,创建一个表,删除一张表,修改表,输出插入,修改,数据删除,数据获取,显示表信息,过滤查询,分页查询,地理hash
- JAVA对Mysql进行连接、插入、修改、删除操作
- Delphi ADOQuery连接数据库的查询、插入、删除、修改
- Delphi ADOQuery连接数据库的查询、插入、删除、修改
- Delphi ADOQuery连接数据库的查询、插入、删除、修改
- 用C语言操作MySQL数据库,进行连接、插入、修改、删除等操作
- 如何读取配置文件并连接后台数据库,且对数据库进行操作实例(查询或修改等)
- JAVA对MYSQL进行连接、插入、修改、删除操作
- 操作数据库添加、修改、删除、查询的代码
- 基础--JAVA对Mysql进行连接、插入、修改、删除操作