«

怎么使用JDBC连接数据库并执行SQL语句

时间：2024-5-19 09:48     作者：韩俊     分类： Mysql

今天小编给大家分享一下怎么使用JDBC连接数据库并执行SQL语句的相关知识点，内容详细，逻辑清晰，相信大部分人都还太了解这方面的知识，所以分享这篇文章给大家参考一下，希望大家阅读完这篇文章后有所收获，下面我们一起来了解一下吧。

1. JDBC入门

JDBC（Java Database Connectivity）是Java程序与数据库进行交互的一种标准接口，它提供了一种简单的方式来连接和操作数据库。在使用JDBC之前，需要先了解以下几个概念：

    JDBC Driver：JDBC驱动程序是一个Java类，用于将Java应用程序与特定数据库管理系统（DBMS）连接。JDBC驱动程序分为四种类型：JDBC-ODBC桥接驱动程序、本地API驱动程序、网络协议驱动程序和本地协议驱动程序。

    Connection：Connection是一个JDBC接口，用于连接到数据库。在Java程序中，通过Connection接口的实现类来实现与数据库的连接。

    Statement：Statement是一个JDBC接口，用于向数据库发送SQL语句并执行它们。在Java程序中，通过Connection对象创建Statement对象。

    ResultSet：ResultSet是一个JDBC接口，用于表示从数据库中检索到的结果集。ResultSet对象通过Statement对象的executeQuery()方法返回。

下面是一个简单的JDBC连接示例：

import java.sql.*;
public class JDBCDemo {
    public static void main(String[] args) {
        try {
            // 加载JDBC驱动程序
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 建立数据库连接
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/mydb", "root", "password");
            // 执行SQL查询
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM users");
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getString(3));
            }
            // 关闭数据库连接
            rs.close();
            stmt.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

2. 抽取工具类

在实际开发中，我们通常会抽取出一个JDBC工具类来封装JDBC相关操作，以方便代码的重用和维护。下面是一个简单的JDBC工具类示例：

import java.sql.*;
public class JDBCUtils {
    private static final String URL = "jdbc:mysql://localhost:3306/mydb";
    private static final String USER = "root";
    private static final String PASSWORD = "password";
    static {
        try {
            // 加载JDBC驱动程序
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    public static Connection getConnection() {
        Connection conn = null;
        try {
            // 建立数据库连接
            conn = DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return conn;
    }
    public static void release(ResultSet rs, Statement stmt, Connection conn) {
        try {
            if (rs != null) rs.close();
            if (stmt != null) stmt.close();
            if (conn != null) conn.close();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

3. Statement CRUD

Statement是JDBC中最基本的操作方式，它用于向数据库发送SQL语句并执行它们。下面是一个使用Statement进行CRUD操作的示例：

import java.sql.*;
public class StatementCRUD {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtils.getConnection();
            stmt = conn.createStatement();
            // 插入数据
            String sql = "INSERT INTO users (name, age) VALUES ('Tom', 18)";
            stmt.executeUpdate(sql);
            // 更新数据
            sql = "UPDATE users SET age = 20 WHERE name = 'Tom'";
            stmt.executeUpdate(sql);
            // 删除数据
            sql = "DELETE FROM users WHERE age = 20";
            stmt.executeUpdate(sql);
            // 查询数据
            sql = "SELECT * FROM users";
            rs = stmt.executeQuery(sql);
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getInt(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, stmt, conn);
        }
    }
}

4. 演练CRUD

下面是一个使用PreparedStatement进行CRUD操作的示例：

import java.sql.*;
public class PreparedStatementCRUD {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtils.getConnection();
            // 插入数据
            String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "Tom");
            pstmt.setInt(2, 18);
            pstmt.executeUpdate();
            // 更新数据
            sql = "UPDATE users SET age = ? WHERE name = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.setString(2, "Tom");
            pstmt.executeUpdate();
            // 删除数据
            sql = "DELETE FROM users WHERE age = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.executeUpdate();
            // 查询数据
            sql = "SELECT * FROM users";
            pstmt = conn.prepareStatement(sql);
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getInt(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, pstmt, conn);
        }
    }
}

5. Dao模式(声明与实现分开)

Dao（Data Access Object）模式是一种用于封装数据访问逻辑的设计模式。它将数据访问逻辑与业务逻辑分离开来，使得代码更易于维护和扩展。下面是一个使用Dao模式进行CRUD操作的示例：

import java.sql.*;
public class UserDAO {
    private static final String INSERT_SQL = "INSERT INTO users (name, age) VALUES (?, ?)";
    private static final String UPDATE_SQL = "UPDATE users SET age = ? WHERE name = ?";
    private static final String DELETE_SQL = "DELETE FROM users WHERE age = ?";
    private static final String SELECT_SQL = "SELECT * FROM users";
    public void insert(User user) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(INSERT_SQL);
            pstmt.setString(1, user.getName());
            pstmt.setInt(2, user.getAge());
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(null, pstmt, conn);
        }
    }
    public void update(User user) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(UPDATE_SQL);
            pstmt.setInt(1, user.getAge());
            pstmt.setString(2, user.getName());
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(null, pstmt, conn);
        }
    }
    public void delete(int age) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(DELETE_SQL);
            pstmt.setInt(1, age);
            pstmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(null, pstmt, conn);
        }
    }
    public List<User> selectAll() {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        List<User> userList = new ArrayList<>();
        try {
            conn = JDBCUtils.getConnection();
            pstmt = conn.prepareStatement(SELECT_SQL);
            rs = pstmt.executeQuery();
            while (rs.next()) {
                User user = new User();
                user.setId(rs.getInt(1));
                user.setName(rs.getString(2));
                user.setAge(rs.getInt(3));
                userList.add(user);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, pstmt, conn);
        }
        return userList;
    }
}
public class User {
    private int id;
    private String name;
    private int age;
    // 省略getter、setter方法
}

6. PrepareStatement CRUD

PreparedStatement是一种预编译的Statement，它可以通过占位符的方式来替换SQL语句中的参数，避免了SQL注入的危险。下面是一个使用PreparedStatement进行CRUD操作的示例：

import java.sql.*;
public class PrepareStatementCRUD {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            conn = JDBCUtils.getConnection();
            // 插入数据
            String sql = "INSERT INTO users (name, age) VALUES (?, ?)";
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, "Tom");
            pstmt.setInt(2, 18);
            pstmt.executeUpdate();
            // 更新数据
            sql = "UPDATE users SET age = ? WHERE name = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.setString(2, "Tom");
            pstmt.executeUpdate();
            // 删除数据
            sql = "DELETE FROM users WHERE age = ?";
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);
            pstmt.executeUpdate();
            // 查询数据
            sql = "SELECT * FROM users";
            pstmt = conn.prepareStatement(sql);
            rs = pstmt.executeQuery();
            while (rs.next()) {
                System.out.println(rs.getInt(1) + ", " + rs.getString(2) + ", " + rs.getInt(3));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JDBCUtils.release(rs, pstmt, conn);
        }
    }
}

标签: mysql

热门推荐

1 MySQL下载安装、配置与使用教程详细版（win7x64）
2 mysql5.7.17 zip 解压安装详细过程
3 nodejs进阶(6)—连接MySQL数据库示例
4 Mysql中varchar长度设置方法
5 批量 kill mysql 中运行时间长的sql
6 Mysql中 unique列插入重复值该怎么解决呢
7 学会设置MySQL数据库的五个常用参数
8 window平台安装MongoDB数据库图文详解
9 MYSQL的select 学习笔记
10 php+mysql实现无限级分类

日历

标签

hbase maven eclipse sybase PostgreSQL spring emcache oracle mongodb redis nginx golang java vue android ios mysql linux 微信小程序 css html php教程 javascript python php

搜索

最新文章

热门文章