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();
		}

	}

}