JDBC链接数据库并进行增删改查操作全过程
1、JDBC全流程
首先，我们先对整个JDBC链接数据库并进行增删改查进行说明
以下，我们先对整个框架进行说明：
- 首先我们创建my.properties配置文件，里面记录着Driver驱动、MySQL路径、MySQL用户名及密码
- 第二步，我们将建立Config类，用此类读取我们一开始配置好的文件，能够做到，给定一个key，就能获取对应的Value。
- 第三步，我们建立BassDaoImp类，此类的作用，就是获取连接数据库的Connection，对查询、增删改及关闭链接进行封装，能够做到，创建此类对象，调用此类方法，可进行链接数据、对数据库表查询、对数据库表进行增删改操作、并关闭链接。
- 上三步做完，我们基本就实现了JDBC链接数据库并进行增删改查的操作，下面几步就是对我们封装的方法进行测试。
- 建立Company类，Company是我们本次链接数据库中的一张表，建立此类的目的就是对表中的属性进行封装，能够set和get。
- 最后建立测试类BassDaoCompany，此类中将设立通过c_id（这是Company表中的主键）查询公司信息、通过c_id删除数据、增加数据、通过c_id 修改公司的工作地点。
2、此过程运用到的类和方法
- properties类，用来读取配置文件，其中有个load（InputStream stream）方法，从输入流中读取数据；getProperty(String key)方法，用指定的key，来获取value。
- Class类，getClassLoader（）:类加载器；getResourceAsStream（）:查找资源文件，并且此方法依赖于类加载器；forName（）:执行当前类的加载器。
- Connection接口：负责连接数据库并担任传送数据的任务，如：连接数据库，要有一个通道，那么这个通道就是Connection。
- Statement 接口：由Connection产生，执行SQL语句。
- ResultSet 接口：执行SQL后的结果集。
3、详细的代码及注释如下
1、my.properties配置文件
Driver=com.mysql.jdbc.Driver
Url=jdbc:mysql://localhost:3306/blog
User=root
Password=123456
2、Config类
package com.pb.news.util;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
//此类设立的目的在于获取到配置文件（my.properties）中的数据
public class Config {
//在java中有个properties类，用来读取配置文件，因此首先创建properties的变量
public static Properties pros = null;
//使用static{}语句块，在类加载时执行且仅会执行一次
static {
//创建pros对象
pros=new Properties();
//通过properties的load读取数据，但load是从输入流中读取，因此我们需要将文件读取到输入流中
/*在java.long.Class类中通过getClassLoader类加载器
和查找资源方法getResourceAsStream（此方法依赖于Class Loader），其方法返回InputStream对象
注意：properties文件要放在src目录下，如此在编译完成后，会自动将此文件复制到class目录下*/
InputStream stream = Config.class.getClassLoader().getResourceAsStream("my.properties");
//再调用load方法
try {
pros.load(stream);//此时，已经将my.properties的配置文件内容读取到pros实例中
} catch (IOException e) {
e.printStackTrace();
}
}
//通过properties中的getProperty（String key）方法来获取对应的value值
//getProperty（String key）方法:用指定的键在此属性列表中搜索属性。也就是通过参数 key，得到 key 所对应的 value。
//建立静态方法
public static String getValue(String key){
return pros.getProperty(key);
}
//测试，能否获取
public static void main(String[] args) {
System.out.println(Config.getValue("Url"));
}
}
3、BassDaoImp类
package com.pb.news.imp;
import com.pb.news.util.Config;
import java.sql.*;
public class BassDaoImp {
//此类的作用是加载JDBC驱动、链接数据库、关闭链接；并对数据实现增删改查的封装
//首先，在整个链接数据库并实现操作的过程中需要三种对象
//第一种：Connection对象，其意义是链接数据库的对象，代表一个数据库连接
private Connection conn = null;
//第二种是Statement对象，
//Statement对象是执行SQL语句，必须要创建的一个对象
//其分为三种实例对象
//1、执行静态SQL语句：使用Statement实例实现
//2、执行动态SQL语句：使用PreparedStatement实例实现
//3、执行数据路存储过程，使用CallableStatement实例实现
//本文件使用的是动态SQL语句，进行增删改查操作
//并且使用PreparedStatement:是Statement的子接口,可以传入带占位符的SQL语句，提供了补充占位符变量的方法
private PreparedStatement ps = null ;
//第三种是ResultSet对象，此对象是执行完SQL语句后返回的一个结果集
private ResultSet rs = null;
//首先我们来实现对JDBC驱动的加载，和链接数据库的方法,此方法返回一个连接Connection实例
public Connection getConnection(){
//第一步加载驱动，实际就是将com.jdbc.mysql.Driver类加载到java虚拟机中
//使用Class类中forName方法：执行当前类的加载器
try {
//调用Config类的方法获取配置文件中的值
Class.forName(Config.getValue("Driver"));
//在将Driver类成功加载后，Driver类中会将Driver类的实例注册到DriverManage类中
//DriverManager类是管理一组 JDBC 驱动程序的基本服务，用来获取数据库的连接
//DriverManager类的获取连接的方法：getConnection（URL ， username ， password）
//连接数据库
conn = DriverManager.getConnection(Config.getValue("Url"),
Config.getValue("User"),
Config.getValue("Password"));
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
//返回一个数据库连接
return conn ;
}
//加载完驱动并连接上数据库之后，我们开始对数据库进行SQL语句操作了，
// 首先我们先进行SQL查询语句操作
//此方法需要传入两个参数，一个是SQL语句，另一个是SQL语句中的参数
public ResultSet select(String sql , Object[] objects){
//1、加载驱动，连接数据库
conn = this.getConnection() ;
try {
//给出SQL模板,调用Connection中的prepareStatement（）方法，返回的是创建好的一个prepareStatement对象
// 传入SQL语句模板并和PreparedStatement实例连接在一起，传入到数据库中进行检验
ps = conn.prepareStatement(sql);
//对模板中的？进行赋值，调用ps中的setXXX（）方法进行传入数据库中进行赋值
for (int i=0 ; i<objects.length ; i++ ){
ps.setObject(i+1,objects[i]); //此处要注意：传入参数的下标，是从1开始的
}
//准备好后，开始执行SQL语句,并对结果进行接收，使用PreparedStatement接口自己的方法
rs = ps.executeQuery();
} catch (SQLException e) {
e.printStackTrace();
}
return rs ;
}
//同样，我们对数据库进行增、删、改操作
public int Update(String sql , Object[] objects){
int flog= 0 ;
conn = this.getConnection() ;
try {
ps = conn.prepareStatement(sql);
for (int i=0 ; i<objects.length ; i++ ){
ps.setObject(i+1,objects[i]);
}
//进行增、删、改操作，返回的是一个整数，如果返回的数大于0，则说明操作成功
flog= ps.executeUpdate();
if (flog>0){
System.out.println("True！");
}else {
System.out.println("False!");
}
} catch (SQLException e) {
e.printStackTrace();
}finally {
//关闭链接
try {
Close();
} catch (SQLException e) {
e.printStackTrace();
}
}
return flog ;
}
//执行完SQL后，最重要的就是关闭链接，对Connection、PreparedStatement、ResultSet进行关闭
public void Close( ) throws SQLException {
if (conn!=null) conn.close();
if (ps!=null) ps.close();
if (rs!=null) rs.close();
}
}
4、封装Company表中的属性Company类
package com.pb.news.model;
//此类主要是对blog数据库中的company表中的属性进行封装
//以便我们可以更方便的获取company表中的数据
public class Company {
//公司id
private int cid;
//职位名
private String zwName;
//公司名称
private String cname;
//公司地点
private String place;
//公司性质
private String cxz;
//公司规模
private String cgm;
//公司产业
private String ccy;
//最低薪资
private Double lsalary;
//最高薪资
private Double hsalary;
@Override
public String toString() {
return "Company{" +
"cid=" + cid +
", zwName='" + zwName + '\'' +
", cname='" + cname + '\'' +
", place='" + place + '\'' +
", cxz='" + cxz + '\'' +
", cgm='" + cgm + '\'' +
", ccy='" + ccy + '\'' +
", lsalary=" + lsalary +
", hsalary=" + hsalary +
'}';
}
public void setCid(int cid) {
this.cid = cid;
}
public void setZwName(String zwName) {
this.zwName = zwName;
}
public void setCname(String cname) {
this.cname = cname;
}
public void setPlace(String place) {
this.place = place;
}
public void setCxz(String cxz) {
this.cxz = cxz;
}
public void setCgm(String cgm) {
this.cgm = cgm;
}
public void setCcy(String ccy) {
this.ccy = ccy;
}
public void setLsalary(Double lsalary) {
this.lsalary = lsalary;
}
public void setHsalary(Double hsalary) {
this.hsalary = hsalary;
}
public int getCid(int anInt) {
return cid;
}
public String getZwName() {
return zwName;
}
public String getCname() {
return cname;
}
public String getPlace() {
return place;
}
public String getCxz() {
return cxz;
}
public String getCgm() {
return cgm;
}
public String getCcy() {
return ccy;
}
public Double getLsalary() {
return lsalary;
}
public Double getHsalary() {
return hsalary;
}
}
5、测试BassDaoCompany类
package com.pb.news.model;
import com.pb.news.imp.BassDaoImp;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.List;
public class BassDaoCompany {
//在此类中，我们要实现四种方式： 1、通过搜索company表中的c_id 属性来查询到此公司的详细信息
// 2、通过c_id删除数据
// 3、增加数据
// 4、通过c_id 修改公司的工作地点
//首先是查询数据，并返回company集合
public Company Select(int cid){
BassDaoImp bass = new BassDaoImp() ;
Company company =new Company();
//查询模板
String sql = "select * from company where c_id=?";
Object[] objects = new Object[1];
objects[0]=cid ;
//调用
ResultSet rs = bass.select(sql, objects);
try {
while (rs.next()){
company.setCid(rs.getInt(1));
company.setZwName(rs.getString(2).trim());
company.setCname(rs.getString(3).trim());
company.setPlace(rs.getString(4).trim());
company.setCxz(rs.getString(5).trim());
company.setCgm(rs.getString(6).trim());
company.setCcy(rs.getString(7).trim());
company.setLsalary(rs.getDouble(8));
company.setHsalary(rs.getDouble(9));
}
//关闭
bass.Close();
} catch (SQLException e) {
e.printStackTrace();
}
return company ;
}
//增加
public void Add(Object[] objects) {
BassDaoImp bass = new BassDaoImp();
Company company = new Company();
//查询模板
String sql = "insert into company values(?,?,?,?,?,?,?,?,?)";
//调用
bass.Update(sql, objects);
//关闭
try {
bass.Close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//删除
public void Delete(int cid) {
BassDaoImp bass = new BassDaoImp();
Company company = new Company();
//查询模板
String sql = "delete from company where c_id=?";
Object[] objects = new Object[1];
objects[0]=cid;
//调用
bass.Update(sql, objects);
//关闭
try {
bass.Close();
} catch (SQLException e) {
e.printStackTrace();
}
}
//修改数据工作地点
public void Upt(Object[] objects) {
BassDaoImp bass = new BassDaoImp();
Company company = new Company();
//查询模板
String sql = "update company set 工作地点=? where c_id=?";
//调用
bass.Update(sql, objects);
//关闭
try {
bass.Close();
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
BassDaoCompany bassCompany = new BassDaoCompany();
//查询
System.out.println("以下是查询操作,查询c_id=500的公司信息：");
Company select = bassCompany.Select(500);
System.out.println(select.toString());
//增加
System.out.println("以下的增加的操作：");
Object[] objects1 = new Object[]{9995 ,"大数据工程师","徐州超神有限公司","徐州",
"开发","超级大规模","研发/教育",10000,200000};
bassCompany.Add(objects1);
//删除
System.out.println("删除：");
bassCompany.Delete(9998);
//修改
System.out.println("修改：");
Object[] objects2 = new Object[]{"徐州",548};
bassCompany.Upt(objects2);
}
}
- 测试结果：
以上就是全过程，希望对大家有所帮助！若有不对的地方，请及时指出！感谢。