大家好，又见面了，我是你们的朋友全栈君。
MySQL的JDBC连接
- MySQL的JDBC概念
-
- MySQL的JDBC
- JDBC添加数据
- 封装连接工具
- 更新数据和事务
- 删除数据
- 查询数据
MySQL的JDBC概念
JDBC 是 Java Database Connective的缩写，表示使用Java去连接数据库进行数据操作的过程
MySQL的JDBC
- 创建动态项目-以eclipse为例，首先要创建动态项目
- 连接开发包（在www.mvnrepository.com下载）
- 在项目中导入驱动包
- 可以使用build-path配置方式导入驱动包
- 也可以直接将驱动包拷贝到项目的 lib 目录下
JDBC添加数据
使用Java连接数据库
代码语言：javascript复制package com.berger.test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class TestMysql {
//链接地址
private static String URL = "jdbc:mysql://localhost:3306/demo?useSSL=true&useUnicode=true&characterEncoding=UTF-8";
//驱动名称
private static String DRIVER = "com.mysql.jdbc.Driver";
//用户名
private static String USER = "root";
//密码
private static String PASSWORD = "1234";
//加载驱动信息
static {
try {
Class.forName(DRIVER);
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws Exception {
//获取Connection对象
Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);
System.out.println(conn);
//准备一条sql语句
String sql = "INSERT INTO emp(empno,ename,job,sal,hiredate,mgr,comm,deptno) "
"VALUES(1002,'张三','总裁',9000,NOW(),null,2000,10)";
//获取发送sql语句的对象
//获取方法一，PreparedStatement可以对sql语句预编译，在数据库中直接执行，效率高
// PreparedStatement pst = conn.prepareStatement(sql);
// int row = pst.executeUpdate();
// System.out.println("插入了 " row " 行数据。");
//获取方法二,Statement不会进行预编译，且容易出现错误
Statement st = conn.createStatement();
int row = st.executeUpdate(sql);
System.out.println("插入了 " row " 行数据。");
}
}封装连接工具
将连接代码放入一个工具类
代码语言：javascript复制package com.berger.utils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ConnectionUtil {
//数据库地址
private static String URL="jdbc:mysql://localhost:3306/demo?useSSL=true&useUnicode=true&characterEncoding=UTF-8";
//取得驱动程序
private static String DRIVER="com.mysql.jdbc.Driver";
//取得用户
private static String USER="root";
//登录密码
private static String PASSWORD="1234";
//静态代码块加载驱动类信息
static {
try {
Class.forName(DRIVER);//将"com.mysql.jdbc.Driver"类的Class类对象加载到运行时内存中
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
//定义获取Connection对象的方法
public static Connection getConnection() {
//定义Connection对象
Connection conn = null;
if (conn == null) {
try {
conn = DriverManager.getConnection(URL, USER, PASSWORD);
} catch (SQLException e) {
e.printStackTrace();
}
}
return conn;
}
public static void close(Connection conn) {
if (conn != null) {
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}更新数据和事务
测试封装好的工具类，更新数据
代码语言：javascript复制/** * 更新数据 * @param count * @return * @throws SQLException */
public static boolean updateEmp(double count) throws SQLException {
//取得Connection对象
Connection conn = ConnectionUtil.getConnection();
//准备sql语句
String sql1 = "UPDATE emp SET despoint = despoint-" count "WHERE ename = 'SMITH'";
String sql2 = "UPDATE emp SET despoint = despoint " count "WHERE ename = 'cmm'";
//定义两个变量接收执行sql语句的返回值
int row1 = 0;
int row2 = 0;
//关闭事务自动提交
conn.setAutoCommit(false);
//获取发送sql的对象
try {
PreparedStatement pst1 = conn.prepareStatement(sql1);
PreparedStatement pst2 = conn.prepareStatement(sql2);
row1 = pst1.executeUpdate();
row2 = pst2.executeUpdate();
//判断数据库修改是否合理
if (!(row1>0 && row2>0)) {
conn.rollback();
}
//正常执行完成未发生异常，提交事务
conn.commit();
} catch (Exception e) {
//发生异常则事务回滚
conn.rollback();
e.printStackTrace();
}
ConnectionUtil.close(conn);
return row1>0 && row2>0;
}在更新数据和事务中需要保证事务的原子性和数据的一致性
删除数据
删除单条数据
代码语言：javascript复制/** * 删除单条数据 * @param id 要删除的数据id * @return * @throws Exception */
public static boolean deleteById(Integer id) throws Exception {
//获取connection对象
Connection conn = ConnectionUtil.getConnection();
//准备sql语句
String sql = "DELETE FROM emp WHERE empno = " id;
//取得预编译对象
PreparedStatement pst = conn.prepareStatement(sql);
//执行sql语句
int row = pst.executeUpdate();
//关闭连接
ConnectionUtil.close(conn);
return row > 0;
}批量删除数据
代码语言：javascript复制/** * 批量删除数据 * @param ids 要删除的数据的id的集合 * @return 删除成功返回 true，删除失败返回false * @throws Exception */
public static boolean deleteBatch(Set<Integer> ids) throws Exception{
//获取Connection对象
Connection conn = ConnectionUtil.getConnection();
//准备sql语句，使用StringBuffer
StringBuffer sql = new StringBuffer();
sql.append("DELETE FROM emp WHERE empno IN (");
//迭代器遍历集合取得所有的员工编号
Iterator<Integer> it = ids.iterator();
while (it.hasNext()) {
sql.append(it.next() ",");
}
sql.delete(sql.length()-1, sql.length());
sql.append(")");
//取得预编译对象
PreparedStatement pst = conn.prepareStatement(sql.toString());
//执行sql语句
int row = pst.executeUpdate();
//关闭连接
ConnectionUtil.close(conn);
return row>0;
}查询数据
根据id查询数据
代码语言：javascript复制/** * 根据id查询数据 * @param id 要查询的数据的id * @throws Exception */
public static void selectById(Integer id) throws Exception {
//取得连接对象
Connection conn = ConnectionUtil.getConnection();
//准备sql语句
String sql = "SELECT * FROM emp WHERE empno = " id;
//取得预编译对象
PreparedStatement pst = conn.prepareStatement(sql);
//执行sql语句
ResultSet rs = pst.executeQuery();
//判断返回值是否存在，并取出返回值
if (rs.next()) {
//写法一
System.out.println("员工编号:" rs.getInt(1) "rn姓名:" rs.getString(2) "rn职位:" rs.getString(3) "rn直接领导:" rs.getInt(4) "rn入职日期:" rs.getDate(5)
"rn薪资:" rs.getDouble(6) "rn佣金:" rs.getDouble(7) "rn部门编号:" rs.getInt(8));
//写法二
System.out.println("员工编号:" rs.getObject("empno") "rn姓名:" rs.getObject("ename") "rn职位:" rs.getObject("job") "rn直接领导:" rs.getObject("mgr")
"rn入职日期:" rs.getObject("hiredate") "rn薪资:" rs.getObject("sal") "rn佣金:" rs.getObject("comm") "rn部门编号:" rs.getObject("deptno"));
}
//关闭连接对象
ConnectionUtil.close(conn);
}模糊查询
代码语言：javascript复制/** * 实现模糊分页查询 * @param kw 模糊查询的关键字 * @param cp 分页查询所在的页码 * @param ls 每页的数据量 * @throws Exception */
public static void selectSplitAll(String kw, int cp, int ls) throws Exception {
//拼接关键字
if (kw == null) {
kw = "";
}
kw = "'%" kw "%'";
//获取连接对象
Connection conn = ConnectionUtil.getConnection();
//准备sql语句
String sql = "SELECT * FROM emp WHERE ename LIKE " kw " LIMIT " (cp-1)*ls "," ls;
//获取预编译对象
PreparedStatement pst = conn.prepareStatement(sql);
//执行sql语句
ResultSet rs = pst.executeQuery();
while (rs.next()) {
System.out.println("员工编号:" rs.getObject("empno") "rn姓名:" rs.getObject("ename") "rn职位:" rs.getObject("job") "rn直接领导:" rs.getObject("mgr")
"rn入职日期:" rs.getObject("hiredate") "rn薪资:" rs.getObject("sal") "rn佣金:" rs.getObject("comm") "rn部门编号:" rs.getObject("deptno"));
System.out.println("--------------------------------");
}
//关闭连接
pst.close();
rs.close();
ConnectionUtil.close(conn);
}发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/160532.html原文链接：https://javaforall.cn
