Java数据库通用操作类的代码

        Java操作数据库主要有以下三个步骤：1）查找数据库驱动；2）生成Connection对象;3)生成Statement对象，然后使用Statement对象进行数据库的增删改查操作。为了更加方便使用，对上述操作进行封装，增删改三个操作封装为update方法，参数为标准的SQL语句，返回值为boolean类型；查询封装为query方法，方法的参数也为标准的查询SQL语句，返回为记录集ResultSet；单独编写initialize方法实现配置文件读取，Connection对象生成，Statement生成等操作，并将initialize()方法与类的构造函数合并，即一生成类对象即完成初始化操作；close()方法实现了对数据资源回收工作，值得注意的是在初始化操作时，是先生成Connection对象，再生成Statement对象，而关闭时是先关闭Statement对象再关闭Connection对象，这一点一定要注意。

        数据库类中可能发生变化的内容：数据库驱动，url,用户名和密码，单独在配置文件中，防止发生变化时需要修改和重新编译代码。

        配置文件内容如下：

driver=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8
username=root
password=test

        具体DBProcess.java的代码如下：

package edu.sgit.db;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;
/*
 * 表名：test
 * id       int 自增
 * username varchar(50)
 * password varchar(50)
 * 
 */
//insert into test(username,password) 
//	               values('admin','111');
//update test set password='222' where id=1
//update test set password='222' where username='admin'
//delete from test where id=1;
// delete from test where username='admin'
// select * from test where username='admin'
public class DBProcess {
private Connection conn = null;
private Statement  stmt = null;

public DBProcess(){
initialize();
}

public void initialize(){
try{
String driver="";//数据库驱动类
String url="";
String username="";
String password="";

//读配置文件，获取,driver,url,username,password
InputStream in = this.getClass().getResourceAsStream("prop.properties"); //字节流
Properties prop = new Properties(); 
try {
   prop.load(in); 
} catch (IOException e) { 
   e.printStackTrace(); 
} 
driver = prop.getProperty("driver");
url=prop.getProperty("url");
username = prop.getProperty("username");
password = prop.getProperty("password");

//1.查找数据库驱动
Class.forName(driver);//查找数据库驱动
//2.建立数据库连接，并生成相应的连接对象
conn = DriverManager.getConnection(url,username,password);//建立数据库连接
//3.生成数据库操作对象stmt
stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
}catch(Exception ex){
ex.printStackTrace();
}
}

//在数据表中添加，修改，删除一条记录
public boolean update(String sql){
try{
//添加
//insert into test(username,password) 
            //  values('admin','111');
//修改数据库记录
//update test set password='222222' where id=1,
//删除记录
//sql = "delete from test where id=8"
stmt.executeUpdate(sql);
return true;
}catch(Exception ex){
ex.printStackTrace();
return false;
}
}

//查询结果
//sql ="select * from test"
public ResultSet query(String sql){
try{
return stmt.executeQuery(sql);
}catch(Exception ex){
ex.printStackTrace();
return null;
}
}

public void close(){
try{
if(stmt!=null)
stmt.close();
if(conn!=null)
conn.close();
}catch(Exception ex){
ex.printStackTrace();
}
}
}

测试代码：

package edu.sgit.test;

import java.sql.ResultSet;

import edu.sgit.db.DBProcess;

public class DBTest {

public static void main(String[] args) {
/*

+--------+--------------+------+-----+---------+----------------+
| Field  | Type         | Null | Key | Default | Extra          |
+--------+--------------+------+-----+---------+----------------+
| Id     | int(11)      | NO   | PRI | NULL    | auto_increment |
| title  | varchar(100) | YES  |     | NULL    |                |
| msg    | text         | YES  |     | NULL    |                |
| inDate | datetime     | YES  |     | NULL    |                |
| count  | int(11)      | YES  |     | 0       |                |
+--------+--------------+------+-----+---------+----------------+
 * */
DBProcess db = new DBProcess();
//add
String title="abc";
String msg="msg_0001";
String date="2020-09-20 10:45:23";
int count=100;
int id=8;

//如果字段是字符，变量前后加'',如果字段是数值类型，不加单引号
//title:'aaa0000'
//count:100
String sql0="insert into msg(title,msg,inDate,count) values('abc','msg_0001','2020-09-20 10:45:23',100)";

String sql1="insert into msg(title,msg,inDate,count) values('";
sql1 = sql1 + title +"','";
sql1 = sql1 + msg +"','";
sql1 = sql1 + date +"',";
sql1 = sql1 + count +")";
System.out.println(sql1);

boolean flag = db.update(sql1);
if(flag) {
System.out.println("add ok!");
}else {
System.out.println("add error!");
}

//update
sql1 ="update msg set title='";
sql1 = sql1+title+"' where id="+id;
flag = db.update(sql1);
if(flag) {
System.out.println("udpate ok!");
}else {
System.out.println("udpate error!");
}

//delete
sql1 ="delete from msg where id="+id;
flag = db.update(sql1);
if(flag) {
System.out.println("delete ok!");
}else {
System.out.println("delete error!");
}

//query
sql1 ="select * from msg";
ResultSet rs = db.query(sql1);
try {
while(rs.next()) {
System.out.print(rs.getInt("id"));
System.out.print("\t");
System.out.print(rs.getString("title"));
System.out.print("\t");
System.out.print(rs.getString("msg"));
System.out.print("\t");
System.out.print(rs.getString("inDate"));
System.out.print("\t");
//System.out.print(rs.getInt("count"));
//System.out.print("\n");
}
}catch(Exception ex) {
ex.printStackTrace();
}

}

}