1. 说明
用Java语言操作Mysql，首先需要学习Mysql
安装教程详见：一、安装、连接以及配置MySQL
Mysql基础教程详见：「MySQL」从零到删库
2. JDBC的由来以及定义
JDBC是什么？
- Java数据库连接(Java Database Connectivity)简称JDBC
- JDBC是Java操作各数据库的一种规范，是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。JDBC是面向关系型数据库的
打个比方？
- 假设Java公司是布料厂，那么各SQL数据库公司就是服装设计厂
- Java公司规定JDBC接口，允许去操作各数据库，相当于提供原材料
- 各SQL公司去实现接口，相当于拿原材料设计出自己的服装
3. JDBC体验，statement.executeQuery() 查询
首先要导入MySQL jar包，其相当于物流公司，将布料厂的原材料运输到服装设计厂里，让服装厂设计
Java MySQL Connector/J 包下载详见：MySQL Connector/J
下载好的jar包拖入lib文件夹下
引入jar包并导入库中
连接数据库并创建一个Info表
创建JDBCDemo类写入代码，导入包所用到的方法都是在 java.sql里的，import java.sql.*
4. 整理和释放
规范代码
public class JDBCDemo01 { public static final String URL = "jdbc:mysql://127.0.0.1:3306/student"; public static final String USER = "root"; public static final String PASSWORD = "xxxxxx"; public static final String DRIVER = "com.mysql.jdbc.Driver"; public static Connection connection; public static Statement statement; public static ResultSet resultSet; public static void main(String[] args) { try { //1.加载驱动程序，给布料厂打电话，我是mysql公司的 Class.forName(DRIVER); //2.获得数据库的连接，告诉物流具体走什么路线 connection = DriverManager.getConnection(URL, USER, PASSWORD); //3.获取数据库操作对象，货送到了，然后卸货到仓库 statement = connection.createStatement(); //4.从仓库中筛选出要用的货，查询Sql语句 resultSet = statement.executeQuery("SELECT * FROM info"); while (resultSet.next()){ int id = resultSet.getInt(1); String name = resultSet.getString(2); int age = resultSet.getInt(3); System.out.println("[" + id + ","+ name+ "," + age + "]"); } //5.完成所有操作，关闭结果，关闭仓库，再关闭数据库连接 } catch (Exception e) { e.printStackTrace(); }finally { try { resultSet.close(); statement.close(); connection.close(); } catch (Exception e) { e.printStackTrace(); } } } }
5. 封装JDBCUtils
如果每次查询都要重新写配置文件是件很麻烦的事，可以将配置文件封装起来，在src下创建db.properties配置文件，写入配置项
创建com.google.util包，创建JDBCUtils类
public class JDBCUtils { private static String url; private static String user; private static String password; private static String driver; //静态代码，做预处理 static { try { //JDBCUtils.class.getClassLoader() //读取配置文件 InputStream inputStream = ClassLoader.getSystemResourceAsStream("db.properties"); //加载对象 Properties properties = new Properties(); properties.load(inputStream); //读取配置项 url = properties.getProperty("url"); user = properties.getProperty("user"); password = properties.getProperty("password"); driver = properties.getProperty("driver"); } catch (Exception e) { e.printStackTrace(); } } //4.测试是否加载成功 public static void init(){ System.out.println("加载成功"); } //5.创建单例，获取配置项 public static Connection getConnection() throws SQLException{ return DriverManager.getConnection(url, user, password); } //6.释放，关闭结果，关闭仓库，关闭数据库连接 public static void close(Connection connection, Statement statement, ResultSet resultSet) throws SQLException { if (resultSet != null){ resultSet.close(); } if (statement != null){ statement.close(); } if (connection != null){ connection.close(); } } public static void close(Connection connection, Statement statement) throws SQLException { if (statement != null){ statement.close(); } if (connection != null){ connection.close(); } } }
创建测试类，测试能否加载JDBCUtils
6. 增删改 —— executeUpdate()
确认获取数据库连接和操作对象信息
只有查询是executeQuery()，增删改都是executeUpdate()
运行代码查看数据库已经插入成功
更新或者删除，也是同理
运行代码查看数据库已经更新成功
public void UpdateTest(){ try { //1.获取数据库连接和操作对象 connection = JDBCUtils.getConnection(); statement = connection.createStatement(); //2.更新一条数据 String sql = "update info set name ='Pig' where id = 4"; int res = statement.executeUpdate(sql); //3.判断数据是否更新成功 if (res != 0){ System.out.println("Update success"); } } catch (Exception e) { e.printStackTrace(); } finally { try { //4.调用重载方法，关闭仓库和数据库连接 JDBCUtils.close(connection, statement); } catch (SQLException e) { e.printStackTrace(); } } }
7. 字符编码问题
如果插入中文时乱码怎么办？
- 字符编码问题，需要更改数据库、IDE、终端的编码格式为
UTF-8，在配置项中添加字符编码
url = jdbc:mysql://127.0.0.1:3306/student?characterEncoding=utf-8 user = root password = xxxxxx driver = com.mysql.jdbc.Driver
8. PreparedStatement和问号占位符
如果要求用户输入数据，需要用户手动编写sql语句吗？
- 不需要，用
PreparedStatement就可以
PreparedStatement是什么？
PreparedStatement是预编译的，可以简化执行查询或者更新数据表数据，对于批量处理可以大大提高效率，也叫JDBC存储过程
public interface PreparedStatement extends Statement;
Statement和PreparedStatement的区别？
- 使用
Statement需要进行拼写SQl语句
resultSet = statement.executeQuery("SELECT * FROM info"); while (resultSet.next()){ int id = resultSet.getInt(1); String name = resultSet.getString(2); int age = resultSet.getInt(3); System.out.println("[" + id + ","+ name+ "," + age + "]"); }
- 使用
PreparedStatement是Statement的子接口，可以传入带占位符的SQL语句，提供了补充占位符变量的方法，preparedStatement()要求写入sql语句
preparedStatement = connection.prepareStatement(sql);
package com.company; import com.google.util.JDBCUtils; import org.junit.Test; import java.util.*; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.sql.Statement; import java.util.Scanner; /** * @author:Yeats * @description: * @date: 4/4/2022 * @time: 4:35 PM */ public class JDBCDemo03 { public static Connection connection; public static PreparedStatement preparedStatement; public static void main(String[] args) { try { //1.获取数据库连接和操作对象 connection = JDBCUtils.getConnection(); //2.用户输入信息，使用占位符的sql语句，更新一条数据 String sql = "INSERT INTO info(name, age) values(?, ?)"; System.out.println("请先输入姓名，再输出年龄，用回车隔开："); Scanner scanner = new Scanner(System.in); String name = scanner.nextLine(); int age = scanner.nextInt(); //3.preparedStatement传入带占位符的sql语句，set方法设置每一个位置的值，并执行更新操作 preparedStatement = connection.prepareStatement(sql); preparedStatement.setString(1, name); preparedStatement.setInt(2, age); int res = preparedStatement.executeUpdate(); //4.判断数据是否更新成功 if (res != 0){ System.out.println("Update success"); } } catch (Exception e) { e.printStackTrace(); } finally { try { //5.调用重载方法，释放资源 JDBCUtils.close(connection, preparedStatement); } catch (SQLException e) { e.printStackTrace(); } } } }
注意，parameterindex是指传入问号的下标
同时需要更改配置文件JDBCUtils类中的Statement成PreparedStatement
package com.google.util; import javax.swing.*; import java.io.InputStream; import java.sql.*; import java.util.Properties; /** * @author:Yeats * @description: * @date: 4/4/2022 * @time: 9:30 AM */ public class JDBCUtils { private static String url; private static String user; private static String password; private static String driver; //静态代码，做预处理 static { try { //JDBCUtils.class.getClassLoader() //读取配置文件 InputStream inputStream = ClassLoader.getSystemResourceAsStream("db.properties"); //加载对象 Properties properties = new Properties(); properties.load(inputStream); //读取配置项 url = properties.getProperty("url"); user = properties.getProperty("user"); password = properties.getProperty("password"); driver = properties.getProperty("driver"); } catch (Exception e) { e.printStackTrace(); } } //4.测试是否加载成功 public static void init(){ System.out.println("加载成功"); } //5.创建单例，获取配置项 public static Connection getConnection() throws SQLException{ return DriverManager.getConnection(url, user, password); } //6.释放资源，关闭结果，关闭仓库，关闭数据库连接 public static void close(Connection connection, PreparedStatement preparedStatement, ResultSet resultSet) throws SQLException { if (resultSet != null){ resultSet.close(); } if (preparedStatement != null){ preparedStatement.close(); } if (connection != null){ connection.close(); } } public static void close(Connection connection, PreparedStatement preparedStatement) throws SQLException { if (preparedStatement != null){ preparedStatement.close(); } if (connection != null){ connection.close(); } } }
运行成功
如果要执行查询操作，需要将excuteUpdate()改成excuteQuery()，大体上与Statement形式相同
9. 最终Demo说明
最好一次性学完，做好准备，头脑清晰再去学
10. 对象的封装，重构代码， 学生管理系统模块化编程
项目源代码下载详见：面向对象大胆向前！Java API实战-视频和资料-Frank
IDEA导入有jar包的Java项目(版本2019.3.2)，点击import
找到项目的位置，点OK
选择从已存在的源文件创建项目
确认项目名称与路径
已找到项目的源文件，请选择被添加到项目的根中，确认项目根目录
检查导入的jar包，并勾选jar包
审查建议的项目模块结构。在此阶段，您可以设置模块名称，从项目中排除特定模块，合并或拆分单个模块。所有模块之间的依赖关系都将自动更新，就像库中的依赖项一样
查看项目结构，手动导入所有jar包
直接运行项目会抛出SQL异常，需要更改db.properties代码，将localhost改成127.0.0.1:3306
url = jdbc:mysql://127.0.0.1:3306/student?characterEncoding=utf-8 user = root password = xxxxxx driver = com.mysql.jdbc.Driver
