Java中数据库操作中的事务实现(JDBC)

发表评论

基本实现先参照：Java简单完整数据库操作全过程(JDBC)

事务的支持其实只需要在Statement对象执行SQL之前开启事务，执行之后提交事务，出现异常情况回滚数据即可，分别对应三个方法：

  • setAutoCommit(boolean)：参数为false则开启事务
  • commit()：提交事务
  • rollback()：回滚事务

这三个方法是数据库连接类Connection的对象方法。

实现参考：

package com.yusian.transaction;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class TransactionDemo {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;
        try {
            conn = Utils.getConnection();
            pstmt1 = conn.prepareStatement("update account set balance = balance - ? where id = ?");
            pstmt2 = conn.prepareStatement("update account set balance = balance + ? where id = ?");
            pstmt1.setDouble(1, 500);
            pstmt1.setInt(2, 1);
            pstmt2.setDouble(1, 500);
            pstmt2.setInt(2, 2);
            // 重点来了，开启事务和不开启事务就只有这一点差别
            conn.setAutoCommit(false);  // 开启事务
            pstmt1.executeUpdate();
            pstmt2.executeUpdate();     // 提交事务
            conn.commit();
        } catch (Exception e) {
            e.printStackTrace();
            try {
                // 事务回滚，注意：回滚应该在所有的异常捕获中执行，因为无论发生何种异常，都应该回滚。
                conn.rollback();
            } catch (SQLException sqlException) {
                sqlException.printStackTrace();
            }
        }finally {
            // 资源释放
            Utils.releaseCloseableObject(pstmt1);
            Utils.releaseCloseableObject(pstmt2);
            Utils.releaseCloseableObject(conn);
        }
    }
}

继续阅读 →

Java模拟用户名密码登录验证(JDBC)

发表评论

0、示例程序说明

  • 演示登录验证，用户通过终端输入用户名与密码，程序连接数据库查询合法性；
  • 基本步骤：
    • 获取数据库连接对象
    • 获取SQL执行对象
    • 执行SQL获取结果对象
    • 处理结果
  • 执行SQL语句有两个类，Statement与PrepareStatement，后者是前者的子类，后者有防SQL流入的功能

1、封装工具类操作数据库

package com.yusian.utils;

import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;

public class Utils {
    private static String url;  // 数据库连接url
    private static String user; // 数据库用户名
    private static String pass; // 数据库密码
    private static String driver;

    /**
     * 读取配置文件初始化参数值
     */
    static {
        // 通过ClassLoader获取配置文件的路径
        ClassLoader loader = Utils.class.getClassLoader();
        URL jdbc = loader.getResource("jdbc.properties");
        try {
            // 通过Properties类读取配置文件中的数据，赋值给静态变量
            Properties prop = new Properties();
            prop.load(new FileReader(jdbc.getPath()));
            url = prop.getProperty("url");
            user = prop.getProperty("user");
            pass = prop.getProperty("pass");
            driver = prop.getProperty("driver");
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * 获取数据库连接
     * @return 数据库连接对象Connection
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException {
        // 注册MySQL驱动类
        try {
            Class.forName(driver);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
        // 获取MySQL连接对象
        return DriverManager.getConnection(url, user, pass);
    }

    /**
     * 释放更新类数据库操作对象
     * @param conn 数据库连接对象
     * @param stmt SQL语句执行对象
     */
    public static void releaseExcuteUpdate(Connection conn, Statement stmt) {
        releaseCloseableObject(stmt);
        releaseCloseableObject(conn);
    }

    /**
     * 释放查询类数据库操作对象
     * @param conn 数据库连接对象
     * @param stmt SQL执行对象
     * @param retSet 查询结果
     */
    public static void releaseExecuteQuery(Connection conn, Statement stmt, ResultSet retSet) {
        releaseCloseableObject(retSet);
        releaseExcuteUpdate(conn, stmt);
    }
    /**
     * 释放资源
     * @param object 需要释放的资源对象
     */
    private static void releaseCloseableObject(AutoCloseable object) {
        if (object == null) return;
        try {
            object.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

继续阅读 →

Java简单完整数据库操作全过程(JDBC)

1条回复

1、基本概念与步骤

1.1 初始化JDBC

jdbc定义的是一套接口，每种数据库类型都有各自的实现，我们调用的都是接口，编译器可能并不清楚该采用哪种实例，所以需要先初始化。

Class.forName("com.mysql.jdbc.Driver");

1.2 数据库连接对象(Connection类)

String connectUrl = "jdbc:mysql://example.domain.com:3306/db3?useSSL=false";
Connection conn = DriverManager.getConnection(connectUrl, "user", "password");

1.3 执行SQL(Statement类)

两个重要的方法：

  • executeUpdate 执行DML语句和DDL语句，即数据或库表的增删改操作；
  • executeQuery 执行DQL语句，即数据库的查询操作；
String sql = "select * from xxx";
Statement stmt = conn.createStatement();
ResultSet resultSet = stmt.executeQuery(sql);
while (resultSet.next()) {
    String uname = resultSet.getString("column1");
    int balance = resultSet.getInt("column2");
    System.out.println(uname + "--" + balance);
}

1.4 释放资源

stmt.close();
conn.close();

继续阅读 →