Mysql的JDBC连接和CRUD操作

本文主要是介绍Mysql的JDBC连接和CRUD操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

本文目的:演示用Eclipse编写Java项目实现数据库的连接和基本的增删改查操作

项目结构如下图所示：

这里写图片描述

数据库结构如下：

CREATE TABLE `stu` (`id` int(11) NOT NULL AUTO_INCREMENT,`name` varchar(20) COLLATE utf8_bin DEFAULT NULL,`age` int(3) DEFAULT NULL,`gradeid` int(11) DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=17 DEFAULT CHARSET=utf8 COLLATE=utf8_bin

这里写图片描述

database-info.properties配置文件如下：

driver=com.mysql.jdbc.Driver
#tcjt084 is your database's name
url=jdbc:mysql://localhost:3306/tcjt084
#root is your database username
user=root
#admin is your database password
password=admin

Student.java建实体类如下

package entity;//实体类
public class Stu {private int id;private String name;private int age;public Stu() {}public Stu(int id, String name, int age) {super();this.id = id;this.name = name;this.age = age;}public int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}@Overridepublic String toString() {return "Stu [id=" + id + ", name=" + name + ", age=" + age + "]";}}

ReadDBInfo.java工具类读取数据库信息如下：

package jdbc;import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;
import java.util.Properties;public class ReadDBInfo {// 单例模式对象声明 静态私有private static ReadDBInfo prop = null;// Properties对象Properties p = new Properties();// 私有构造方法，一定要是私有的，私有外部就不能直接new本类对象了，实现单例模式目的private ReadDBInfo() {}/*** 单例模式* @return 本类的对象*/public static ReadDBInfo getInstance() {if (prop == null) {prop = new ReadDBInfo();}return prop;}/*** @param key:关键字* @return String 根据key读取到的properties中的值*/public String getDBInfo(String key) {try {// Creates a new FileReader, //given the name of the file to read from.//创建一个新的FileReader，给定要读取的文件的名称。FileReader fr = new FileReader("src/database-info.properties");// Reads a property list (key and element pairs) from //the input character stream in a simple line-oriented format. //从输入字符流中读取一个属性列表(键和元素对)，以一个简单的行为导向的格式p.load(fr);// 根据properties 返回key的值/*Searches for the property with the specified key in this property list.If the key is not found in this property list, the default property list, and its defaults, recursively, are then checked. The method returns null if the property is not found.*///在属性列表中搜索具有指定键的属性。//如果在此属性列表中没有找到该键，则会对默认属性列表及其默认值进行递归检查。//如果没有找到该属性，该方法将返回null。return p.getProperty(key);} catch (FileNotFoundException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}return null;}
}

BaseDao.java如下：

package dao;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;import jdbc.ReadDBInfo;public class BaseDao {ReadDBInfo prop = ReadDBInfo.getInstance();// 获取driver url user password值,从properties文件中String driver = prop.getDBInfo("driver");String url = prop.getDBInfo("url");String user = prop.getDBInfo("user");String password = prop.getDBInfo("password");// 数据库连接对象Connection conn = null;// sql语句处理对象PreparedStatement ps = null;// 结果集对象ResultSet rs = null;/*** 与数据库建立起连接* @return void*/public void getConn() {try {//加载驱动//使用给定的字符串名称返回与类或接口关联的类对象。//调用此方法等价于：类。//forName(className,true,currentLoader)：//当前加载器表示当前类的定义类装入器。Class.forName(driver);//获取与数据库的连接//尝试建立与给定数据库URL的连接。//DriverManager试图从注册的JDBC驱动程序中选择适当的驱动程序。//注意:如果用户或密码属性也被指定为url的一部分，//那么它将被定义为哪个值优先。//为了获得最大的可移植性，应用程序应该只指定一次属性。conn = DriverManager.getConnection(url, user, password);} catch (ClassNotFoundException e) {e.printStackTrace();} catch (SQLException e) {e.printStackTrace();}}/*** 关闭rs,ps,conn* @return void*/public void closeAll() {if (rs != null) {try {rs.close();} catch (SQLException e) {e.printStackTrace();}}if (ps != null) {try {ps.close();} catch (SQLException e) {e.printStackTrace();}}if (conn != null) {try {conn.close();} catch (SQLException e) {e.printStackTrace();}}}/*** 执行sql语句获取查找到的结果集* @param objs* obj数组 用来存放sql中?的值* @param sql* sql语句* @return ResultSet 返回结果集*/public ResultSet baseSelect(Object[] objs, String sql) {getConn();/* * 创建一个PreparedStatement对象，用于向数据库发送参数化的SQL语句。* 具有或不带参数的SQL语句可以预编译并存储在PreparedStatement对象中。* 然后可以使用此对象多次有效地执行此语句。*/ps = conn.prepareStatement(sql);for (int i = 0; i < objs.length; i++) {/** 使用给定对象设置指定参数的值。* JDBC规范指定了从Java对象类型到SQL类型的标准映射。* 在发送到数据库之前，给定的参数将转换为相应的SQL类型。*/ps.setObject(i + 1, objs[i]);}/** 在这个PreparedStatement对象中执行SQL查询，* 并返回由查询生成的ResultSet对象。* 返回类型：包含查询生成的数据的ResultSet对象;没有空*/rs = ps.executeQuery();return rs;} catch (SQLException e) {e.printStackTrace();}return null;}/*** 执行sql语句对数据库中的数据进行操作，增删改* @param objs* obj数组 用来存放sql中?的值* @param sql* sql语句* @return int 有多少条数据被修改*/public int baseUpdate(Object[] objs, String sql) {getConn();try {ps = conn.prepareStatement(sql);for (int i = 0; i < objs.length; i++) {ps.setObject(i + 1, objs[i]);}/** 在这个PreparedStatement对象中执行SQL语句，* 它必须是一个SQL数据操作语言(DML)语句，如插入、更新或删除;* 或者一个没有返回任何内容的SQL语句，比如DDL语句。*/int lines = ps.executeUpdate();return lines;} catch (SQLException e) {e.printStackTrace();}return 0;}
}

StuDao接口如下：

package dao;import java.util.List;import entity.Stu;public interface StuDao {List<Stu> getAll();Stu getStuById(int id);int getCount();boolean update(Stu s);boolean delete(int id);boolean add(Stu s);
}

StuDaoImpl实现StuDao接口：

package dao;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;import entity.Stu;public class StuDaoImpl extends BaseDao implements StuDao {/*** 查找所有信息* @return Stu类的List*/@Overridepublic List<Stu> getAll() {String sql = "select * from stu";ResultSet rs = baseSelect(new Object[] {}, sql);//构造一个初始容量为10的空列表。存放Student对象List<Stu> list = new ArrayList<>();try {//rs.next():/** 将光标从当前位置向前移动一行。* 一个ResultSet游标最初定位在第一行之前;* 第一个对方法的调用使第一行成为当前行;* 第二个调用使第二行变成当前行，以此类推。* 当对下一个方法的调用返回false时，光标将位于最后一行之后。*/while (rs.next()) {Stu s = new Stu();/** 在这个ResultSet对象的当前行中检索指定列的值，* 作为Java编程语言中的int类型。*/s.setId(rs.getInt("id"));s.setName(rs.getString("name"));s.setAge(rs.getInt("age"));list.add(s);}return list;} catch (SQLException e) {e.printStackTrace();}return null;}/*** 根据id查找Stu* @param id* @return Stu对象*/@Overridepublic Stu getStuById(int id) {String sql = "select * from stu where id=?";Object[] objs = new Object[] { id };ResultSet rs = baseSelect(objs, sql);Stu s = new Stu();try {while (rs.next()) {s.setId(rs.getInt("id"));s.setName(rs.getString("name"));s.setAge(rs.getInt("age"));}return s;} catch (SQLException e) {e.printStackTrace();}return null;}/*** 一共有多少条信息* @return int*/@Overridepublic int getCount() {String sql = "select count(*) from stu";ResultSet rs = baseSelect(new Object[] {}, sql);int count = 0;try {while (rs.next()) {count = rs.getInt(1);}return count;} catch (SQLException e) {e.printStackTrace();}return 0;}/*** 更新Stu信息* @param Stu s:Stu对象* @return boolean true 成功 false 失败*/@Overridepublic boolean update(Stu s) {String sql = "update stu set name=?,age=? where id=?";Object[] objs = new Object[] { s.getName(), s.getAge(), s.getId() };int lines = baseUpdate(objs, sql);if (lines > 0) {return true;}return false;}/*** 根据id删除信息* @param id:id * @return boolean true 成功 false 失败*/@Overridepublic boolean delete(int id) {String sql = "delete from stu where id=?";Object[] objs = new Object[] { id };int lines = baseUpdate(objs, sql);if (lines > 0) {return true;}return false;}/*** 添加Stu信息* @param s:要添加的对象* @return boolean true 成功 false 失败*/@Overridepublic boolean add(Stu s) {String sql = "insert into stu values(null,?,?)";Object[] objs = new Object[] { s.getName(), s.getAge() };int lines = baseUpdate(objs, sql);if (lines > 0) {return true;}return false;}
}

Test类测试如下：

package test;import java.util.List;
import java.util.Scanner;import org.junit.Before;
import org.junit.Test;import dao.StuDao;
import dao.StuDaoImpl;
import entity.Stu;public class Tests {private StuDao dao;@Beforepublic void init() {dao = new StuDaoImpl();}// 查所有@Testpublic void testGetAll() {List<Stu> list = dao.getAll();for (Stu s : list) {System.out.println(s);}}// 查记录数@Testpublic void testGetCounts() {System.out.println(dao.getCount());}// 根据id查找@Testpublic void testGetStuById() {Scanner input = new Scanner(System.in);System.out.println("请输入要查询的id:");int id = input.nextInt();Stu s = dao.getStuById(id);if (s == null) {System.out.println("未查询到结果！");} else {System.out.println(s);}input.close();}// 新增学生信息@Testpublic void testAdd() {Scanner input = new Scanner(System.in);System.out.println("请输入姓名:");String name = input.next();System.out.println("请输入年龄:");String ageStr = input.next();int age = Integer.parseInt(ageStr);System.out.println(dao.add(new Stu(0, name, age)));input.close();}// 删除学生信息@Testpublic void testDel() {Scanner input = new Scanner(System.in);System.out.println("请输入要删除的id:");int id = input.nextInt();System.out.println(dao.delete(id));input.close();}// 修改学生信息@Testpublic void testUpd() {Scanner input = new Scanner(System.in);System.out.println("请输入ID:");int id = input.nextInt();System.out.println("请输入姓名:");String name = input.next();System.out.println("请输入年龄:");String ageStr = input.next();int age = Integer.parseInt(ageStr);System.out.println(dao.update(new Stu(id, name, age)));input.close();}
}