package com.itheima;import com.itheima.utils.JdbcUtils;import java.sql.*;import java.util.Scanner;public class Demo07Login {public static void main(String[] args) {// 1)  得到用户从控制台上输入的用户名和密码Scanner scanner = new Scanner(System.in);System.out.println("请输入用户名：");String name = scanner.nextLine();System.out.println("请输入密码：");String password = scanner.nextLine();// 2)  调用下面写的登录方法来实现登录login(name, password);}//使用子接口：PreparedStatementprivate static void login(String name, String password) {//1. 得到连接对象Connection conn = null;PreparedStatement ps = null;ResultSet rs = null;try {conn = JdbcUtils.getConnection();//2. 创建语句对象，使用占位符ps = conn.prepareStatement("select * from user where name=? and password=?");//3. 设置占位符的真实值ps.setString(1, name);ps.setString(2, password);//4. 查询rs = ps.executeQuery();//5. 判断是否登录成功if (rs.next()) {System.out.println("登录成功，" + name);} else {System.out.println("登录失败");}} catch (Exception e) {e.printStackTrace();} finally {//6. 关闭连接JdbcUtils.close(conn, ps, rs);}}/*//Statement登录的方法private static void login(String name, String password) {//a)   通过工具类得到连接Connection conn = null;Statement stmt = null;ResultSet rs = null;try {conn = JdbcUtils.getConnection();//b)    创建语句对象，使用拼接字符串的方式生成SQL语句stmt = conn.createStatement();String sql = "select * from user where name='" + name + "' and password='" + password + "'";System.out.println(sql);rs = stmt.executeQuery(sql);//c)    查询数据库，如果有记录则表示登录成功，否则登录失败if (rs.next()) {//登录成功System.out.println("登录成功，欢迎您：" + name);} else {System.out.println("登录失败，请重试");}} catch (SQLException e) {e.printStackTrace();} finally {//d)    释放资源JdbcUtils.close(conn, stmt, rs);}}*/}

public class Demo07Login {public static void main(String[] args) {// 1)  得到用户从控制台上输入的用户名和密码Scanner scanner = new Scanner(System.in);System.out.println("请输入用户名：");String name = scanner.nextLine();System.out.println("请输入密码：");String password = scanner.nextLine();// 2)  调用下面写的登录方法来实现登录login(name, password);}//使用子接口：PreparedStatementprivate static void login(String name, String password) {//1. 得到连接对象Connection conn = null;PreparedStatement ps = null;ResultSet rs = null;try {conn = JdbcUtils.getConnection();//2. 创建语句对象，使用占位符ps = conn.prepareStatement("select * from user where name=? and password=?");//3. 设置占位符的真实值ps.setString(1, name);ps.setString(2, password);//4. 查询rs = ps.executeQuery();//5. 判断是否登录成功if (rs.next()) {System.out.println("登录成功，" + name);} else {System.out.println("登录失败");}} catch (Exception e) {e.printStackTrace();} finally {//6. 关闭连接JdbcUtils.close(conn, ps, rs);}}}

表与类的关系

 //每个方法都可以运行, 必须是public void 方法不能有参数@Testpublic void testFindOne() throws SQLException {//1)   创建一个学生对象Student student = new Student();//2)   得到连接对象Connection conn = JdbcUtils.getConnection();//3)   得到语句对象，SQL设置占位符PreparedStatement ps = conn.prepareStatement("select * from student where id=?");//4)   传递参数，替换占位符ps.setInt(1, 1);ResultSet rs = ps.executeQuery();//5)   将结果封装成一个学生对象if (rs.next()) {student.setId(rs.getInt("id"));student.setName(rs.getString("name"));student.setGender(rs.getBoolean("gender"));student.setBirthday(rs.getDate("birthday"));}//6)   释放资源JdbcUtils.close(conn,ps,rs);//7)   使用数据，输出到控制台System.out.println(student);}

@Testpublic void testFindAll() throws SQLException {//1)   创建一个集合用于封装所有的记录List<Student> students = new ArrayList<>();//2)   得到连接对象Connection conn = JdbcUtils.getConnection();//3)   得到语句对象，SQL语句没有占位符PreparedStatement ps = conn.prepareStatement("select * from student");ResultSet rs = ps.executeQuery();//4)   每次循环封装一个学生对象while (rs.next()) {//5)   把数据放到集合中Student student = new Student();student.setId(rs.getInt("id"));student.setName(rs.getString("name"));student.setGender(rs.getBoolean("gender"));student.setBirthday(rs.getDate("birthday"));students.add(student);}//6)   关闭连接JdbcUtils.close(conn,ps,rs);//7)   使用数据，循环输出学生对象students.forEach(System.out::println);}

 //    1)   向学生表中添加1条记录代码@Testpublic void testAdd() throws SQLException {//1.创建连接Connection conn = JdbcUtils.getConnection();//2.创建语句对象PreparedStatement ps = conn.prepareStatement("INSERT  into student VALUES (null,?,?,?)");//3. 替换占位符ps.setString(1, "短笛");ps.setBoolean(2, true);ps.setDate(3, Date.valueOf("1998-02-20"));  //将字符串转成日期，格式必须是：yyyy-MM-dd//4. 执行更新操作int row = ps.executeUpdate();//5.关闭连接JdbcUtils.close(conn, ps);System.out.println("影响的行数：" + row);}//    2)   将id为2的用户，姓名更新为"猪八戒"，性别换成男@Testpublic void testUpdate() throws SQLException {//1.创建连接Connection conn = JdbcUtils.getConnection();//2.创建语句对象PreparedStatement ps = conn.prepareStatement("update student set name=?,gender=? where id=?");//3. 替换占位符ps.setString(1, "猪八戒");ps.setBoolean(2, true);ps.setInt(3, 2);//4. 执行更新操作int row = ps.executeUpdate();//5.关闭连接JdbcUtils.close(conn, ps);System.out.println("影响的行数：" + row);}//    3)   将id为4的学员删除@Testpublic void testDelete() throws SQLException {//1.创建连接Connection conn = JdbcUtils.getConnection();//2.创建语句对象PreparedStatement ps = conn.prepareStatement("delete from student where id=?");//3. 替换占位符ps.setInt(1, 4);//4. 执行更新操作int row = ps.executeUpdate();//5.关闭连接JdbcUtils.close(conn, ps);System.out.println("影响的行数：" + row);}

JDBC事务的处理

之前我们是使用MySQL的命令来操作事务。接下来我们使用JDBC来操作银行转账的事务。

准备数据

CREATE TABLE account (id INT PRIMARY KEY AUTO_INCREMENT,NAME VARCHAR(10),balance DOUBLE
);
-- 添加数据
INSERT INTO account (NAME, balance) VALUES ('Jack', 1000), ('Rose', 1000);

API介绍

开发步骤

• 先试一下没有事务的转账情况
• 使用事务的情况

1. 获取连接
2. 开启事务
3. 获取到PreparedStatement
4. 使用PreparedStatement执行两次更新操作
5. 正常情况下提交事务
6. 出现异常回滚事务
7. 最后关闭资源

• 案例代码

package com.itheima;import com.itheima.utils.JdbcUtils;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.SQLException;public class Demo09Transaction {public static void main(String[] args) {Connection conn = null;PreparedStatement ps = null;try {//1)   获取连接conn = JdbcUtils.getConnection();//开启事务conn.setAutoCommit(false);//3)   获取到PreparedStatementps = conn.prepareStatement("update account set balance = balance - 500 where name='jack'");ps.executeUpdate();System.out.println(100 / 0);//执行第2次ps = conn.prepareStatement("update account set balance = balance + 500 where name='rose'");ps.executeUpdate();//提交事务conn.commit();System.out.println("转账成功");} catch (Exception e) {System.out.println("转账失败");try {conn.rollback();} catch (SQLException e1) {e1.printStackTrace();}} finally {//7)   最后关闭资源JdbcUtils.close(conn, ps);}}}