如何在 Java 中通过JDBC连接 MySQL 数据库

x33g5p2x  于2021-10-15 转载在 Java  
字(4.9k)|赞(0)|评价(0)|浏览(380)

JDBC 简介

JDBC 是标准 Java API 之一,用于在 Java 编程语言和各种数据库之间建立独立于数据库的连接。此 API 允许您使用结构化查询语言 (SQL) 对访问请求语句进行编码。这主要涉及打开连接、创建 SQL 数据库、执行 SQL 查询,然后到达输出。

JDBC API 可用于访问存储在任何关系数据库中的表格数据。有了这个,您可以更新、保存、获取和删除数据库中的数据。它类似于 Microsoft 提供的开放式数据库连接 (ODBC)。

为了更好地理解 JDBC 的工作原理,让我们深入探讨该主题并了解 Java 数据库连接背后的架构。

常见的 JDBC 组件

JDBC API 提供以下接口和类

***DriverManager:***主要用于管理数据库驱动列表。识别某个子协议的驱动程序将用于建立数据库连接。
*
The Driver 是处理与数据库服务器通信的接口。它还抽象了在使用 Driver 对象时关联的细节。
*
*连接 *是一个接口,包含连接到数据库所需的所有方法。连接对象处理数据库的通信功能。语境。

现在让我们继续下一个主题,看看创建 JDBC 应用程序所需的步骤。

创建 JDBC 应用程序的步骤

为了创建 JDBC 应用程序,您需要执行几个步骤。让我们看看它们是什么。

**导入包:*您需要包含所有包含数据库编程所需的 JDBC 类的包。大多数情况下,使用 import java.sql./ 就足够了。
1.
注册 JDBC 驱动程序: 此处必须初始化驱动程序,以便您可以打开与数据库的通信通道。
1.
打开连接: 在这里,您可以使用 getConnection() 方法创建一个 Connection 对象,该对象表示与数据库的物理连接。
1.
**执行查询:**这实际上需要使用 Statement 类型的对象来构建 SQL 语句并将其提交到数据库。
1.
从结果集中提取数据: 建议您使用适当的 getXXX() 方法从结果集中提取数据。
1.
**清理环境:**这里,必须显式关闭所有数据库资源,而不是依赖JVM的垃圾收集。

现在您已经看到了创建 JDBC 应用程序所涉及的各个步骤,让我们看一个创建数据库和建立连接的示例代码。

package Edureka;
import java.sql.*;
import java.sql.DriverManager;
public class Example {
// JDBC driver name and database URL
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
static final String DB_URL = "jdbc:mysql://localhost/emp";
// Database credentials
static final String USER = "root";
static final String PASS = "";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try{
//STEP 2: Register JDBC driver
Class.forName("com.mysql.cj.jdbc.Driver");
//STEP 3: Open a connection
System.out.println("Connecting to database...");
conn = DriverManager.getConnection(DB_URL,"root","");
//STEP 4: Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "SELECT id, first, last, age FROM Employees";
ResultSet rs = stmt.executeQuery(sql);
//STEP 5: Extract data from result set
while(rs.next()){
//Retrieve by column name
int id = rs.getInt("id");
int age = rs.getInt("age");
String first = rs.getString("first");
String last = rs.getString("last");
//Display values
System.out.print("ID: " + id);
System.out.print(", Age: " + age);
System.out.print(", First: " + first);
System.out.println(", Last: " + last);
}
//STEP 6: Clean-up environment
rs.close();
stmt.close();
conn.close();
}catch(SQLException se){
//Handle errors for JDBC
se.printStackTrace();
}catch(Exception e){
//Handle errors for Class.forName
e.printStackTrace();
}finally{
//finally block used to close resources
try{
if(stmt!=null)
stmt.close()
}catch(SQLException se2){
}// nothing can be done
try{
if(conn!=null)
conn.close();
}catch(SQLException se){
se.printStackTrace();
}//end finally try
}//end try
System.out.println("Goodbye!");
}//end main
} // end Example

上面的代码在你的 localhost 数据库中创建了一个表。要在创建的数据库中插入值,您可以参考以下代码。我将只为第 4 步编写代码。其余代码与上述相同。

//STEP 4: Execute a query
System.out.println("Creating table in given database...");
stmt = conn.createStatement();
String sql = "CREATE TABLE EMPLOYEES " +
"(id INTEGER not NULL, " +
" first VARCHAR(255), " +
" last VARCHAR(255), " +
" age INTEGER, " +
" PRIMARY KEY ( id ))";
stmt.executeUpdate(sql);
System.out.println("Created table in given database...");
System.out.println("Inserting records into the table...");
stmt =conn.createStatement();
String sql ="INSERT INTO Employees VALUES (100, 'Kriss', 'Kurian', 18)";
stmt.executeUpdate(sql);
sql = "INSERT INTO Employees VALUES (101, 'Enrique', 'John', 25)";
stmt.executeUpdate(sql);
sql= "INSERT INTO Employees (102, 'Taylor', 'Swift', 30)";
stmt.executeUpdate(sql);
sql= "INSERT INTO Employees VALUES(103, 'Linkin', 'Park', 28)";
stmt.executeUpdate(sql);
System.out.println("Inserted records into the table...");

这就是您如何建立与数据库的连接并在表中插入值的方法。现在让我们进一步了解各种 JDBC 驱动程序类型

JDBC 驱动程序类型

JDBC 驱动程序用于实现 JDBC API 中定义的接口,用于与数据库服务器进行交互。本质上,JDBC 驱动程序做了三件事,它们如下:

  1. 建立与数据源的连接。
  2. 它将向数据源发送查询和更新语句。
  3. 最后,它处理结果。

例如,JDBC 驱动程序通过发送 SQL 或数据库命令帮助您打开数据库连接以与之交互。如果您想了解更多关于 JDBC 驱动程序的类型,您可以参考这篇关于 JDBC 驱动程序的文章。

现在让我们进一步了解 JDBC 连接。

JDBC 连接

**导入 JDBC 包:**将 import 语句添加到您的 Java 程序以导入 Java 代码中所需的类。
*
**注册 JDBC 驱动程序:在这个步骤中,JVM 将所需的驱动程序实现加载到内存中,以便它可以完成 JDBC 请求。有两种方法可以注册驱动程序。

注册驱动最合适的方法是使用Java的**forName()*方法将驱动的类文件动态加载到内存中,内存会自动注册。可配置和便携。看看下面的代码:

try {
Class.forName("oracle.jdbc.driver.OracleDriver");
}
catch(ClassNotFoundException ex) 
System.out.println("Error: unable to load driver class!");
System.exit(1);
}

您可以用来注册驱动程序的第二种方法是使用静态 registerDriver() 方法。

try {
Driver myDriver = new oracle.jdbc.driver.OracleDriver();
DriverManager.registerDriver( myDriver );
}
catch(ClassNotFoundException ex)
{
System.out.println("Error: unable to load driver class!");
System.exit(1);
}

如果您使用的是非 JDK 兼容的 JVM,例如 Microsoft 提供的 JVM,则应使用 registerDriver() 方法。这里每个表单都需要一个数据库 URL
*
**数据库 URL 公式:**URL 公式对于创建格式正确的地址是必要的,该地址指向您要连接的数据库。加载驱动程序后,您可以使用 DriverManager.getConnection() 方法建立连接。 DriverManager.getConnection() 方法是 -

getConnection(字符串网址)
*
getConnection(字符串网址,属性道具)
*
getConnection(String url, String user, String password)

  • 创建连接对象

您可以使用数据库 URL、用户名和密码以及属性对象创建连接。

  • 关闭

最后,要结束数据库会话,您需要关闭所有数据库连接。但是,如果您忘记了,Java 的垃圾收集器会在清理陈旧对象时关闭连接。

conn.close(); // Used to close the connection

相关文章

微信公众号

最新文章

更多