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

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

2012-11-28 23:30 1121 查看
package com.csdn.hbsi.Domain;

public class User {

private int id;

private String name;

private String price;

private String author;

private String description;

public int getId() {

return id;

}

public void setId(int id) {

this.id = id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name = name;

}

public String getPrice() {

return price;

}

public void setPrice(String price) {

this.price = price;

}

public String getAuthor() {

return author;

}

public void setAuthor(String author) {

this.author = author;

}

public String getDescription() {

return description;

}

public void setDescription(String description) {

this.description = description;

}

}

package com.csdn.hbsi.demo;

import java.sql.SQLException;
import java.util.List;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.junit.Test;

import com.csdn.hbsi.domain.User;
import com.csdn.hbsi.utils.DBManager;

public class demo_crud {

@Test
public void insert() throws SQLException {
QueryRunner runner = new QueryRunner(DBManager.getDataSource());
String sql = "insert into users(id,name,price,author,description) values(?,?,?,?,?)";
Object params[] = { 3, "cc", "cc", "cccc", " " };
runner.update(sql, params);
}

@Test
public void update() throws SQLException {
QueryRunner runner = new QueryRunner(DBManager.getDataSource());
String sql = "update users set name=? where id=?";
Object params[] = { "eeee", 3 };
runner.update(sql, params);
}

@Test
public void delete() throws SQLException {
QueryRunner runner = new QueryRunner(DBManager.getDataSource());
String sql = "delete from users where id=?";
Object params[] = { 3 };
runner.update(sql, params);
}

@SuppressWarnings("deprecation")
@Test
public void find() throws SQLException {
QueryRunner runner = new QueryRunner(DBManager.getDataSource());
String sql="select * from users where id=?";
User user=(User) runner.query(sql, 1, new BeanHandler(User.class));
System.out.println(user);
}

@Test
public void findall() throws SQLException {
QueryRunner runner = new QueryRunner(DBManager.getDataSource());
String sql="select * from users";
List list=(List) runner.query(sql, new BeanListHandler(User.class));
System.out.println(list.size());
}

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