如何构建一个高效的MySQL数据库操作通用类？

在当今的软件开发领域，数据库操作是不可或缺的一部分，为了提高开发效率和代码的可维护性，我们通常会创建一个通用的数据库操作类来处理常见的数据库操作任务，本文将介绍一个使用MySQL数据库的通用类，该类可以执行基本的数据库操作，如连接数据库、查询数据、插入数据、更新数据和删除数据。

创建通用类

我们需要创建一个名为DatabaseHelper的通用类，这个类将包含用于连接数据库和执行常见数据库操作的方法。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
public class DatabaseHelper {
    private static final String URL = "jdbc:mysql://localhost:3306/your_database";
    private static final String USER = "your_username";
    private static final String PASSWORD = "your_password";
    // 获取数据库连接
    public static Connection getConnection() throws Exception {
        Class.forName("com.mysql.cj.jdbc.Driver");
        return DriverManager.getConnection(URL, USER, PASSWORD);
    }
    // 关闭资源
    public static void closeResources(Connection conn, Statement stmt, ResultSet rs) {
        try {
            if (rs != null) rs.close();
            if (stmt != null) stmt.close();
            if (conn != null) conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    // 查询数据
    public static List<List<Object>> query(String sql) throws Exception {
        List<List<Object>> results = new ArrayList<>();
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = getConnection();
            stmt = conn.createStatement();
            rs = stmt.executeQuery(sql);
            int columnCount = rs.getMetaData().getColumnCount();
            while (rs.next()) {
                List<Object> row = new ArrayList<>();
                for (int i = 1; i <= columnCount; i++) {
                    row.add(rs.getObject(i));
                }
                results.add(row);
            }
        } finally {
            closeResources(conn, stmt, rs);
        }
        return results;
    }
    // 插入数据
    public static int insert(String sql) throws Exception {
        Connection conn = null;
        Statement stmt = null;
        try {
            conn = getConnection();
            stmt = conn.createStatement();
            return stmt.executeUpdate(sql);
        } finally {
            closeResources(conn, stmt, null);
        }
    }
    // 更新数据
    public static int update(String sql) throws Exception {
        return insert(sql); // 复用insert方法
    }
    // 删除数据
    public static int delete(String sql) throws Exception {
        return insert(sql); // 复用insert方法
    }
}

使用通用类进行数据库操作

下面是一个如何使用DatabaseHelper类进行数据库操作的示例：

public class Main {
    public static void main(String[] args) {
        try {
            // 查询数据
            String querySql = "SELECT * FROM users";
            List<List<Object>> queryResults = DatabaseHelper.query(querySql);
            System.out.println("查询结果: " + queryResults);
            // 插入数据
            String insertSql = "INSERT INTO users (name, age) VALUES ('Alice', 30)";
            int insertCount = DatabaseHelper.insert(insertSql);
            System.out.println("插入记录数: " + insertCount);
            // 更新数据
            String updateSql = "UPDATE users SET age = 31 WHERE name = 'Alice'";
            int updateCount = DatabaseHelper.update(updateSql);
            System.out.println("更新记录数: " + updateCount);
            // 删除数据
            String deleteSql = "DELETE FROM users WHERE name = 'Alice'";
            int deleteCount = DatabaseHelper.delete(deleteSql);
            System.out.println("删除记录数: " + deleteCount);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

相关问答FAQs

Q1: 如何更改数据库连接信息？

A1: 你可以在DatabaseHelper类中更改URL、USER和PASSWORD常量的值来更改数据库连接信息。

private static final String URL = "jdbc:mysql://newhost:3306/newdatabase";
private static final String USER = "newusername";
private static final String PASSWORD = "newpassword";

只需替换这些常量值为新的数据库连接信息即可。

Q2: 如果查询结果为空怎么办？

A2: 如果查询结果为空，query方法将返回一个空的列表，你可以在使用查询结果之前检查列表是否为空，并根据需要进行处理。

List<List<Object>> queryResults = DatabaseHelper.query(querySql);
if (queryResults.isEmpty()) {
    System.out.println("没有找到匹配的记录。");
} else {
    System.out.println("查询结果: " + queryResults);
}

到此，以上就是小编对于“mysql 数据库操作通用类_通用类”的问题就介绍到这了，希望介绍的几点解答对大家有用，有任何问题和不懂的，欢迎各位朋友在评论区讨论，给我留言。