Java作为一种广泛使用的编程语言,其强大的数据库连接能力得益于Java数据库连接(JDBC)API
本文将通过一个具体的JDBC MySQL实例,详细讲解如何使用JDBC连接MySQL数据库,执行SQL语句,并进行数据的读取和处理
通过这一实例,你将深刻理解JDBC的核心概念和操作流程,从而在实际开发中更加高效地管理和操作数据库
一、JDBC简介 JDBC(Java Database Connectivity)是Java平台的一部分,它提供了一套用于执行SQL语句的Java API
JDBC使得Java程序能够与各种数据库进行连接和操作,而不必关心底层数据库的具体实现
JDBC的主要功能包括: 1.连接到数据库:通过JDBC驱动程序与数据库建立连接
2.发送SQL语句:通过连接对象发送SQL语句到数据库
3.处理结果集:从数据库获取结果并进行处理
二、JDBC MySQL 实例准备 在开始之前,你需要确保以下几点: 1.安装Java开发环境:确保你已经安装了JDK,并配置了环境变量
2.安装MySQL数据库:确保MySQL数据库已经安装并运行,且有一个可供连接的数据库和表
3.下载MySQL JDBC驱动:MySQL JDBC驱动可以从MySQL官方网站下载,通常命名为`mysql-connector-java-x.x.xx.jar`
三、JDBC MySQL 实例代码 下面是一个完整的JDBC MySQL实例代码,包括连接到数据库、创建表、插入数据、查询数据,并处理结果集
java import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class JdbcMySqlExample{ // 数据库URL、用户名和密码 private static final String DB_URL = jdbc:mysql://localhost:3306/testdb; private static final String USER = root; private static final String PASS = password; public static void main(String【】 args){ Connection conn = null; Statement stmt = null; try{ // 注册JDBC驱动 Class.forName(com.mysql.cj.jdbc.Driver); // 打开连接 System.out.println(Connecting to database...); conn = DriverManager.getConnection(DB_URL, USER, PASS); // 执行创建表操作 System.out.println(Creating table in given database...); stmt = conn.createStatement(); String sql = CREATE TABLE IF NOT EXISTS Employees + (id INT AUTO_INCREMENT, + name VARCHAR(255), + age INT, + PRIMARY KEY(id)); stmt.executeUpdate(sql); System.out.println(Created table successfully...); // 插入数据到表中 System.out.println(Inserting records into the table...); sql = INSERT INTO Employees(name, age) VALUES(?, ?); PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, John Doe); pstmt.setInt(2, 30); pstmt.executeUpdate(); pstmt.setString(1, Jane Smith); pstmt.setInt(2, 25); pstmt.executeUpdate(); System.out.println(Inserted records successfully...); // 从表中查询数据 System.out.println(Retrieving records from the table...); sql = SELECT id, name, age FROM Employees; ResultSet rs = stmt.executeQuery(sql); // 展开结果集数据库 while(rs.next()){ // 通过字段检索 int id = rs.getInt(id); String name = rs.getString(name); int age = rs.getInt(age); // 输出数据 System.out.print(ID: + id); System.out.print(, Name: + name); System.out.println(, Age: + age); } // 完成后关闭 rs.close(); stmt.close(); conn.close(); } catch(SQLException se){