文档库 最新最全的文档下载
当前位置:文档库 › JAVA 对数据库中数据的增删改查

JAVA 对数据库中数据的增删改查



宠物信息:宠物ID,宠物类别,宠物名字,宠物性别,宠物年龄,宠物入库日期

系统完成功能:实现对宠物信息的录入,修改,删除,查询

解决方法:一共创建了四个类:一个宠物类PetMessage 里面是宠物的信息 一个是数据库连接类DBCon 里面主要是完成数据连接功能 一个是宠物管理类PetDAO 完成对宠物信息的增删该查 最后一个就是一个测试类PetTest 完成对系统的测试

PetMessage类:
package petsys.Pet;
import java.sql.*;
public class PetMessage {
//宠物信息
private int petId;
private String petSort;
private String petName;
private String petSex;
private int petAge;
private String petDate;

public int getPetAge() {
return petAge;
}
public void setPetAge(int petAge) {
this.petAge = petAge;
}
public int getPetId() {
return petId;
}
public void setPetId(int petId) {
this.petId = petId;
}
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 PetMessage(){

}
public String getPetDate() {
return petDate;
}
public void setPetDate(String petDate) {
this.petDate = petDate;
}
public String getPetSort() {
return petSort;
}
public void setPetSort(String petSort) {
this.petSort = petSort;
}
//重载构造函数
public PetMessage(int petId,String petSort,String petName,String petSex,int petAge,String petDate){
this.petId=petId;
this.petSort=petSort;
this.petName=petName;
this.petSex=petSex;
this.petAge=petAge;
this.petDate=petDate;
}
}
DBCon类:
package petsys.Pet;
import java.sql.*;
public class DBCon {

public static Connection getCon(){

try {
Class.forName("com.mysql.jdbc.Driver").newInstance();
Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb","root","root");
return con;
} catch (InstantiationException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
} catch (IllegalAccessException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
return null;
}
//用方法来实现对对象的关闭
public static void closeAllMethod(Connection con,Statement stmt,ResultSet rs){
try {
if(rs!=null){
rs.close();
}
if(stmt!=null){
stmt.close();
}
if(con!=null){
con.close();
}
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
}
PetDAO类:
package petsys.Pet;
import java.sql.*;
public class PetDAO {

//增添宠物信息
public static void doAdd(PetMessage pet){
int petId=pet.get

PetId();
String petSort=pet.getPetSort();
String petName=pet.getPetName();
String petSex=pet.getPetSex();
int petAge=pet.getPetAge();
String petDate=pet.getPetDate();
//与数据库连接
Connection con=null;
con=DBCon.getCon();
//创建会话
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()+"');";
// 执行sql语句
stmt.execute(sqlString);
System.out.println("********************");
System.out.println("宠物添加成功!(^o^)");
System.out.println("********************");
DBCon.closeAllMethod(con,stmt,null);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
//根据宠物ID删除宠物信息
public static void doDeleteWithId(PetMessage pet){
int petId=pet.getPetId();
String petSort=pet.getPetSort();
String petName=pet.getPetName();
String petSex=pet.getPetSex();
int petAge=pet.getPetAge();
String petDate=pet.getPetDate();

//建立数据库连接
Connection con=DBCon.getCon();
//建立会话
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("********************");
DBCon.closeAllMethod(con,stmt,null);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
//根据宠物名字删除宠物信息
public static void doDeleteWithName(PetMessage pet){
int petId=pet.getPetId();
String petSort=pet.getPetSort();
String petName=pet.getPetName();
String petSex=pet.getPetSex();
int petAge=pet.getPetAge();
String petDate=pet.getPetDate();

//建立数据库连接
Connection con=DBCon.getCon();
//建立会话
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("********************");
DBCon.closeAllMethod(con,stmt,null);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
//根据宠物ID修改宠物信息
public static void doUpdateWithID(PetMessage pet){
int petId=pet.getPetId();
String petSort=pet.getPetSort();
String petName=pet.getPetName();
String petSex=pet.getPetSex();
int petAge=pet.getPetAge();
String petDate

=pet.getPetDate();

//建立数据库连接
Connection
con=DBCon.getCon();
//建立会话
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("**********************");
DBCon.closeAllMethod(con,stmt,null);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
//根据宠物名字修改宠物信息
public static void doUpdateWithName(PetMessage pet){
int petId=pet.getPetId();
String petSort=pet.getPetSort();
String petName=pet.getPetName();
String petSex=pet.getPetSex();
int petAge=pet.getPetAge();
String petDate=pet.getPetDate();

//建立数据库连接
Connection con=DBCon.getCon();
//建立会话
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("**********************");
DBCon.closeAllMethod(con,stmt,null);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
//按ID查询宠物信息
public static void doSelectWithId(PetMessage pet){
int petId=pet.getPetId();
String petSort=pet.getPetSort();
String petName=pet.getPetName();
String petSex=pet.getPetSex();
int petAge=pet.getPetAge();
String petDate=pet.getPetDate();
//建立数据库连接
Connection con=DBCon.getCon();
try {
//创建语句对象
Statement stmt=con.createStatement();
//定义sql语句
String sqlString="select * from petMessage where petId="+pet.getPetId()+";";
//创建结果集 并执行sql语句
ResultSet rs=stmt.executeQuery(sqlString);
//对结果集进行解析
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"));
}
DBCon.closeAllMethod(con,stmt,rs);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}


//按名字查询宠物信息
public static void doSelectWithName(PetMessage pet){
int petId=pet.getPetId();
String petSort=pet.g

etPetSort();
String petName=pet.getPetName();
String petSex=pet.getPetSex();
int petAge=pet.getPetAge();
String petDate=pet.getPetDate();
//建立数据库连接
Connection con=DBCon.getCon();
try {
/
/创建语句对象
Statement stmt=con.createStatement();
//定义sql语句
String sqlString="select * from petMessage where petName='"+pet.getPetName()+"';";
//创建结果集 并执行sql语句
ResultSet rs=stmt.executeQuery(sqlString);
//对结果集进行解析
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"));
}
//关闭所以对象
DBCon.closeAllMethod(con,stmt,rs);
} catch (SQLException e) {
// TODO 自动生成 catch 块
e.printStackTrace();
}
}
}

PetTest类:
package petsys.Pet;
public class PetTest {
public static void main(String[] args) {

PetMessage pet=new PetMessage(1,"Cat","咪咪","female",1,"2003-12-21");
PetMessage pet=new PetMessage();
pet.setPetId(1);
pet.setPetName("猫");

//增
PetDAO.doAdd(pet);
//查
PetDAO.doSelectWithId(pet);
PetDAO.doSelectWithName(pet);
//改
PetDAO.doUpdateWithID(pet);
PetDAO.doUpdateWithName(pet);
//删
PetDAO.doDeleteWithId(pet);
PetDAO.doDeleteWithName(pet);
}
}

数据库的表就可以自己建了,只要建好表 然后相应的改变下参数就好了


相关文档