一、需求：
利用jdbc实现对宠物的信息进行管理的一套系统
宠物信息：宠物ID，宠物类别，宠物名字，宠物性别，宠物年龄，宠物入库日期
系统完成功能：实现对宠物信息的录入，修改，删除，查询。
二、解决方案
一共创建了四个类：
1.一个宠物类PetMessage 里面是宠物的信息
2.一个是数据库连接类DBUtil 里面主要是完成数据连接功能
3.一个是宠物管理类PetDAO 完成对宠物信息的增删该查
4.最后一个就是一个测试类PetTest
完成对系统的测试
三、具体实现：
新建一个java项目，并导入需要用到的包。如下图：
宠物类PetMessage
package com.daliu.jdbc; /**
* 宠物信息类
*
*/
public class PetMessage { //1.定义宠物的属性
// 宠物信息：宠物ID，宠物类别，宠物名字，宠物性别，宠物年龄，宠物入库日期
private int petId;
private String petSort;
private String petName;
private String petSex;
private int petAge;
private String petDate; //2.生成一个无参构造方法和有参构造方法 public PetMessage(){} public PetMessage(int petId, String petSort, String petName, String petSex,
int petAge, String petDate) {
super();
this.petId = petId;
this.petSort = petSort;
this.petName = petName;
this.petSex = petSex;
this.petAge = petAge;
this.petDate = petDate;
} //3.生成属性的get，set方法
public int getPetId() {
return petId;
}
public void setPetId(int petId) {
this.petId = petId;
}
public String getPetSort() {
return petSort;
}
public void setPetSort(String petSort) {
this.petSort = petSort;
}
public String getPetName() {
return petName;
}
public void setPetName(String petName) {
this.petName = petName;
}
public String getPetSex() {
return petSex;
}
public void setPetSex(String petSex) {
this.petSex = petSex;
}
public int getPetAge() {
return petAge;
}
public void setPetAge(int petAge) {
this.petAge = petAge;
}
public String getPetDate() {
return petDate;
}
public void setPetDate(String petDate) {
this.petDate = petDate;
} //4.属性的toString方法，并改进为自己所要的样子
@Override
public String toString() {
return "PetMessage [petId=" + petId + ", petSort=" + petSort
+ ", petName=" + petName + ", petSex=" + petSex + ", petAge="
+ petAge + ", petDate=" + petDate + "]";
}
}
数据库连接类DBUtil
package com.daliu.jdbc; import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties; import org.apache.commons.dbcp.BasicDataSource; /**
* 使用连接池技术管理数据库连接
*/
public class DBUtil { // 数据库连接池
private static BasicDataSource dbcp; // 为不同线程管理连接
private static ThreadLocal<Connection> tl; // 通过配置文件来获取数据库参数
static {
try {
Properties prop = new Properties(); InputStream is = DBUtil.class.getClassLoader().getResourceAsStream(
"com/daliu/jdbc/db.properties"); prop.load(is);
is.close(); // 一、初始化连接池
dbcp = new BasicDataSource(); // 设置驱动 (Class.forName())
dbcp.setDriverClassName(prop.getProperty("jdbc.driver"));
// 设置url
dbcp.setUrl(prop.getProperty("jdbc.url"));
// 设置数据库用户名
dbcp.setUsername(prop.getProperty("jdbc.user"));
// 设置数据库密码
dbcp.setPassword(prop.getProperty("jdbc.password"));
// 初始连接数量
dbcp.setInitialSize(Integer.parseInt(prop.getProperty("initsize")));
// 连接池允许的最大连接数
dbcp.setMaxActive(Integer.parseInt(prop.getProperty("maxactive")));
// 设置最大等待时间
dbcp.setMaxWait(Integer.parseInt(prop.getProperty("maxwait")));
// 设置最小空闲数
dbcp.setMinIdle(Integer.parseInt(prop.getProperty("minidle")));
// 设置最大空闲数
dbcp.setMaxIdle(Integer.parseInt(prop.getProperty("maxidle")));
// 初始化线程本地
tl = new ThreadLocal<Connection>();
} catch (Exception e) {
System.out.println("初始化失败，请检查配置文件是否符合！");
e.printStackTrace();
}
} /**
* 获取数据库连接
*
* @return
* @throws SQLException
*/
public static Connection getConnection() throws SQLException {
/*
* 通过连接池获取一个空闲连接
*/
Connection conn = dbcp.getConnection();
tl.set(conn);
return conn;
} /**
* 关闭数据库连接
*/
public static void closeConnection() {
try {
Connection conn = tl.get();
if (conn != null) {
/*
* 通过连接池获取的Connection 的close()方法实际上并没有将 连接关闭，而是将该链接归还。
*/
conn.close();
tl.remove();
}
} catch (Exception e) {
System.out.println("释放资源失败！");
e.printStackTrace();
throw new RuntimeException(e);
}
} /**
* 测试是否连接成功
*
* @param args
* @throws SQLException
*/
public static void main(String[] args) throws SQLException {
System.out.println(getConnection());
}
}
宠物管理类PetDAO
package com.daliu.jdbc; import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement; /**
* 宠物信息操作类
*
*/
public class PetDAO { // 1.增添宠物信息
public static void doAdd(PetMessage pet) { // （1）通过宠物信息类获得宠物信息的定义
int petId = pet.getPetId();
String petSort = pet.getPetSort();
String petName = pet.getPetName();
String petSex = pet.getPetSex();
int petAge = pet.getPetAge();
String petDate = pet.getPetDate(); // （2）与数据库连接
Connection con = null;
try {
con = DBUtil.getConnection();
} catch (SQLException e1) {
e1.printStackTrace();
} // （3）创建会话，执行sql语句
try {
Statement stmt = con.createStatement();
// 定义sql语句
String sqlString = "insert into petmessage(petid,petsort,petname,petsex,petage,petdate) values("
+ pet.getPetId()
+ ",'"
+ pet.getPetSort()
+ "','"
+ pet.getPetName()
+ "','"
+ pet.getPetSex()
+ "',"
+ pet.getPetAge()
+ ",'"
+ pet.getPetDate() + "');"; // （4）执行sql语句
stmt.execute(sqlString); //(5)给出相应的提示
System.out.println("********************");
System.out.println("宠物添加成功！(^o^)");
System.out.println("********************"); //(6)最后释放资源
DBUtil.closeConnection(); } catch (SQLException e) {
// TODO 自动生成 catch 块
System.out.println("增加失败！");
e.printStackTrace(); }
} //2. 根据宠物ID删除宠物信息
public static void doDeleteWithId(PetMessage pet) { //1.获得改宠物的信息
int petId = pet.getPetId();
String petSort = pet.getPetSort();
String petName = pet.getPetName();
String petSex = pet.getPetSex();
int petAge = pet.getPetAge();
String petDate = pet.getPetDate(); // 2.建立数据库连接
Connection con = null;
try {
con = DBUtil.getConnection();
} catch (SQLException e1) {
e1.printStackTrace();
}
//3. 建立会话 ，执行sql语句
try {
Statement stmt = con.createStatement();
// 定义sql语句
String sqlString = "delete from petmessage where petid="
+ pet.getPetId() + ";"; // 执行sql语句
stmt.execute(sqlString); //给出相应的提示
System.out.println("********************");
System.out.println("宠物删除成功！(^o^)");
System.out.println("********************"); //关闭资源
DBUtil.closeConnection(); } catch (SQLException e) {
// TODO 自动生成 catch 块
System.out.println("根据宠物ID删除宠物信息失败！");
e.printStackTrace();
}
} // 3.根据宠物名字删除宠物信息
public static void doDeleteWithName(PetMessage pet) { //(1)获取宠物的信息
int petId = pet.getPetId();
String petSort = pet.getPetSort();
String petName = pet.getPetName();
String petSex = pet.getPetSex();
int petAge = pet.getPetAge();
String petDate = pet.getPetDate(); // （2）建立数据库连接
Connection con = null;
try {
con = DBUtil.getConnection();
} catch (SQLException e1) {
e1.printStackTrace();
}
// （3）建立会话，执行sql语句
try {
Statement stmt = con.createStatement();
// 定义sql语句
String sqlString = "delete from petmessage where petName="
+ pet.getPetName() + ";";
// 执行sql语句
stmt.execute(sqlString);
//给出提示
System.out.println("********************");
System.out.println("宠物删除成功！(^o^)");
System.out.println("********************");
//关闭资源
DBUtil.closeConnection(); } catch (SQLException e) {
// TODO 自动生成 catch 块
System.out.println("根据宠物名字删除宠物信息失败！");
e.printStackTrace();
}
} // 4.根据宠物ID修改宠物信息
public static void doUpdateWithID(PetMessage pet) {
//（1）获取宠物信息
int petId = pet.getPetId();
String petSort = pet.getPetSort();
String petName = pet.getPetName();
String petSex = pet.getPetSex();
int petAge = pet.getPetAge();
String petDate = pet.getPetDate(); // （2）建立数据库连接
Connection con = null;
try {
con = DBUtil.getConnection();
} catch (SQLException e1) {
e1.printStackTrace();
}
// （3）建立会话，执行sql语句
try {
Statement stmt = con.createStatement();
// 定义sql语句
String sqlString = "update petmessage set petName='"
+ pet.getPetName() + "' where petId=" + pet.getPetId()
+ ";";
// 执行sql语句
stmt.execute(sqlString);
//给出相应的提示
System.out.println("**********************");
System.out.println("宠物信息修改成功！(^o^)");
System.out.println("**********************");
//关闭资源
DBUtil.closeConnection();
} catch (SQLException e) {
// TODO 自动生成 catch 块
System.out.println("根据宠物ID修改宠物信息失败");
e.printStackTrace();
}
} // 5.根据宠物名字修改宠物信息
public static void doUpdateWithName(PetMessage pet) {
//（1）获取宠物信息
int petId = pet.getPetId();
String petSort = pet.getPetSort();
String petName = pet.getPetName();
String petSex = pet.getPetSex();
int petAge = pet.getPetAge();
String petDate = pet.getPetDate(); // （2）建立数据库连接
Connection con = null;
try {
con = DBUtil.getConnection();
} catch (SQLException e1) {
e1.printStackTrace();
}
// （3）建立会话，执行sql语句
try {
Statement stmt = con.createStatement();
// 定义sql语句
String sqlString = "update petmessage set petAge='"
+ pet.getPetAge() + "' where petName=" + pet.getPetName()
+ ";";
// 执行sql语句
stmt.execute(sqlString);
//给出相应的提示
System.out.println("**********************");
System.out.println("宠物信息修改成功！(^o^)");
System.out.println("**********************");
//关闭资源
DBUtil.closeConnection();
} catch (SQLException e) {
// TODO 自动生成 catch 块
System.out.println("据宠物名字修改宠物信息失败");
e.printStackTrace();
}
} // 6.按ID查询宠物信息
public static void doSelectWithId(PetMessage pet) {
//（1）获取宠物信息
int petId = pet.getPetId();
String petSort = pet.getPetSort();
String petName = pet.getPetName();
String petSex = pet.getPetSex();
int petAge = pet.getPetAge();
String petDate = pet.getPetDate();
// （2）建立数据库连接
Connection con = null;
try {
con = DBUtil.getConnection();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
try {
// （3）创建语句对象
Statement stmt = con.createStatement();
// （4）定义sql语句
String sqlString = "select * from petMessage where petId="
+ pet.getPetId() + ";";
//（5） 创建结果集 并执行sql语句
ResultSet rs = stmt.executeQuery(sqlString);
//（6）对结果集进行解析
System.out.println("查询结果如下：");
while (rs.next()) {
System.out.println("宠物ID: " + rs.getInt("petId") + " 宠物种类："
+ rs.getString("petSort") + " 宠物名字："
+ rs.getString("petName") + " 宠物性别："
+ rs.getString("petSex") + " 宠物年龄："
+ rs.getInt("petAge") + " 宠物入库时间："
+ rs.getString("petDate"));
} //（7）关闭相应的资源
DBUtil.closeConnection();
} catch (SQLException e) {
// TODO 自动生成 catch 块
System.out.println("按ID查询宠物信息失败");
e.printStackTrace();
}
} // 7.按名字查询宠物信息
public static void doSelectWithName(PetMessage pet) {
//（1）获取宠物信息
int petId = pet.getPetId();
String petSort = pet.getPetSort();
String petName = pet.getPetName();
String petSex = pet.getPetSex();
int petAge = pet.getPetAge();
String petDate = pet.getPetDate();
// （2）建立数据库连接
Connection con = null;
try {
con = DBUtil.getConnection();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
try {
// （3）创建语句对象
Statement stmt = con.createStatement();
//（4） 定义sql语句
String sqlString = "select * from petMessage where petName='"
+ pet.getPetName() + "';";
// （5）创建结果集 并执行sql语句
ResultSet rs = stmt.executeQuery(sqlString);
// （6）对结果集进行解析
System.out.println("查询结果如下：");
while (rs.next()) {
System.out.println("宠物ID: " + rs.getInt("petId") + " 宠物种类："
+ rs.getString("petSort") + " 宠物名字："
+ rs.getString("petName") + " 宠物性别："
+ rs.getString("petSex") + " 宠物年龄："
+ rs.getInt("petAge") + " 宠物入库时间："
+ rs.getString("petDate"));
}
// （7）关闭所以对象
DBUtil.closeConnection();
} catch (SQLException e) {
// TODO 自动生成 catch 块
System.out.println("按名字查询宠物信息失败！");
e.printStackTrace();
}
}
}
测试类PetTest
package com.daliu.jdbc;
public class PetTest {
public static void main(String[] args) {
// 测试数据
// PetMessage pet=new
// PetMessage(1,"leopard","小豹子","female",5,"2014-12-19");
// PetMessage pet1=new
// PetMessage(1,"Dog","小狗狗","female",6,"2014-12-20");
// PetMessage pet2=new
// PetMessage(1,"Cat","小咪咪","female",7,"2014-12-21");
// PetMessage pet3=new
// PetMessage(1,"mouse","小老鼠","female",8,"2014-12-22");
// PetMessage pet4=new
// PetMessage(1,"elephant","大象","female",9,"2014-12-23");
// PetMessage pet5=new
// PetMessage(1,"swan","天鹅","female",10,"2014-12-24");
// 功能测试：
// ****1.增添宠物信息 ********
// PetDAO.doAdd(pet);
// PetDAO.doAdd(pet1);
// PetDAO.doAdd(pet2);
// PetDAO.doAdd(pet3);
// PetDAO.doAdd(pet4);
// PetDAO.doAdd(pet5);
// ****2. 根据宠物ID删除宠物信息 ********
PetMessage pet = new PetMessage(1, "leopard", "小豹子", "female", 5,
"2014-12-19");
pet.setPetId(1);
PetDAO.doSelectWithId(pet);
// ****3.根据宠物名字查询宠物信息 ********
// PetMessage pet = new PetMessage(1, "leopard", "小豹子", "female", 5,
// "2014-12-19");
// pet.setPetName("小老鼠");
// PetDAO.doSelectWithName(pet);
// ****4.根据宠物ID修改宠物信息****
// PetDAO.doUpdateWithID(pet);
// ****5.根据宠物名字修改宠物信息****
// PetDAO.doUpdateWithName(pet);
// ****6.根据宠物ID修改宠物信息****
// PetDAO.doDeleteWithId(pet);
// ****7.根据宠物名字修改宠物信息****
// PetDAO.doDeleteWithName(pet);
}
}
一些测试效果：
SQL脚本：
create database PegSystem;
use PegSystem;
create table pet(
#private int petId;
#private String petSort;
#private String petName;
#private String petSex;
#private int petAge;
#private String petDate;
petId int(7),
petSort varchar(20),
petName varchar(20),
petAge int(4),
petDate varchar(20)
);
#select * from pet;
rename table pet to petMessage;
#select * from petMessage;
alter table petMessage add( petsex varchar(20));
desc petMessage;
select * from petMessage;
配置文件：
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/PegSystem
jdbc.user=root
jdbc.password=123456
initsize=1
maxactive=1
maxwait=5000
maxidle=1
minidle=1
作者：daliu_it
出处：http://www.cnblogs.com/liuhongfeng/p/4173775.html
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接。谢谢合作。