Java查詢(xún)MySQL數(shù)據(jù)庫(kù)
Java是一種廣泛使用的編程語(yǔ)言，而MySQL是一種流行的開(kāi)源關(guān)系型數(shù)據(jù)庫(kù)管理系統(tǒng)。Java與MySQL的結(jié)合，可以讓我們更輕松地操作和管理數(shù)據(jù)庫(kù)。在Java中，我們可以使用JDBC（Java Database Connectivity）來(lái)連接和操作MySQL數(shù)據(jù)庫(kù)。本文將介紹如何使用Java查詢(xún)MySQL數(shù)據(jù)庫(kù)。
_x000D_連接MySQL數(shù)據(jù)庫(kù)
_x000D_在使用Java查詢(xún)MySQL數(shù)據(jù)庫(kù)之前，我們需要先連接數(shù)據(jù)庫(kù)。我們需要下載MySQL的JDBC驅(qū)動(dòng)程序。可以從MySQL官方網(wǎng)站下載，也可以從Maven倉(cāng)庫(kù)中獲取。
_x000D_在Java中，我們可以使用以下代碼連接MySQL數(shù)據(jù)庫(kù)：
_x000D_`java
_x000D_import java.sql.Connection;
_x000D_import java.sql.DriverManager;
_x000D_import java.sql.SQLException;
_x000D_public class MySQLJDBC {
_x000D_public static void main(String[] args) {
_x000D_// JDBC驅(qū)動(dòng)程序類(lèi)名和數(shù)據(jù)庫(kù)URL
_x000D_final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
_x000D_final String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC";
_x000D_// 數(shù)據(jù)庫(kù)用戶(hù)和密碼
_x000D_final String USER = "root";
_x000D_final String PASS = "password";
_x000D_Connection conn = null;
_x000D_try {
_x000D_// 注冊(cè)JDBC驅(qū)動(dòng)程序
_x000D_Class.forName(JDBC_DRIVER);
_x000D_// 打開(kāi)連接
_x000D_System.out.println("連接數(shù)據(jù)庫(kù)...");
_x000D_conn = DriverManager.getConnection(DB_URL, USER, PASS);
_x000D_// 執(zhí)行查詢(xún)
_x000D_// ...
_x000D_} catch (ClassNotFoundException e) {
_x000D_e.printStackTrace();
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_} finally {
_x000D_try {
_x000D_if (conn != null) {
_x000D_conn.close();
_x000D_}
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_}
_x000D_}
_x000D_}
_x000D_ _x000D_在上面的代碼中，我們首先定義了JDBC驅(qū)動(dòng)程序類(lèi)名和數(shù)據(jù)庫(kù)URL。然后，我們使用Class.forName()方法注冊(cè)JDBC驅(qū)動(dòng)程序。接著，使用DriverManager.getConnection()方法打開(kāi)數(shù)據(jù)庫(kù)連接。在finally塊中關(guān)閉連接。
_x000D_執(zhí)行查詢(xún)
_x000D_連接MySQL數(shù)據(jù)庫(kù)后，我們就可以執(zhí)行查詢(xún)了。在Java中，我們可以使用Statement或PreparedStatement對(duì)象執(zhí)行查詢(xún)。Statement對(duì)象用于執(zhí)行靜態(tài)SQL語(yǔ)句，而PreparedStatement對(duì)象用于執(zhí)行動(dòng)態(tài)SQL語(yǔ)句。
_x000D_以下是使用Statement對(duì)象執(zhí)行查詢(xún)的示例代碼：
_x000D_`java
_x000D_import java.sql.Connection;
_x000D_import java.sql.DriverManager;
_x000D_import java.sql.ResultSet;
_x000D_import java.sql.SQLException;
_x000D_import java.sql.Statement;
_x000D_public class MySQLJDBC {
_x000D_public static void main(String[] args) {
_x000D_// JDBC驅(qū)動(dòng)程序類(lèi)名和數(shù)據(jù)庫(kù)URL
_x000D_final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
_x000D_final String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC";
_x000D_// 數(shù)據(jù)庫(kù)用戶(hù)和密碼
_x000D_final String USER = "root";
_x000D_final String PASS = "password";
_x000D_Connection conn = null;
_x000D_Statement stmt = null;
_x000D_ResultSet rs = null;
_x000D_try {
_x000D_// 注冊(cè)JDBC驅(qū)動(dòng)程序
_x000D_Class.forName(JDBC_DRIVER);
_x000D_// 打開(kāi)連接
_x000D_System.out.println("連接數(shù)據(jù)庫(kù)...");
_x000D_conn = DriverManager.getConnection(DB_URL, USER, PASS);
_x000D_// 執(zhí)行查詢(xún)
_x000D_System.out.println("創(chuàng)建Statement對(duì)象...");
_x000D_stmt = conn.createStatement();
_x000D_String sql = "SELECT id, name, age FROM users";
_x000D_rs = stmt.executeQuery(sql);
_x000D_// 處理結(jié)果集
_x000D_while (rs.next()) {
_x000D_int id = rs.getInt("id");
_x000D_String name = rs.getString("name");
_x000D_int age = rs.getInt("age");
_x000D_System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
_x000D_}
_x000D_} catch (ClassNotFoundException e) {
_x000D_e.printStackTrace();
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_} finally {
_x000D_try {
_x000D_if (rs != null) {
_x000D_rs.close();
_x000D_}
_x000D_if (stmt != null) {
_x000D_stmt.close();
_x000D_}
_x000D_if (conn != null) {
_x000D_conn.close();
_x000D_}
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_}
_x000D_}
_x000D_}
_x000D_ _x000D_在上面的代碼中，我們首先創(chuàng)建了一個(gè)Statement對(duì)象。然后，使用executeQuery()方法執(zhí)行查詢(xún)語(yǔ)句，并將結(jié)果存儲(chǔ)在ResultSet對(duì)象中。在while循環(huán)中處理結(jié)果集。
_x000D_以下是使用PreparedStatement對(duì)象執(zhí)行查詢(xún)的示例代碼：
_x000D_`java
_x000D_import java.sql.Connection;
_x000D_import java.sql.DriverManager;
_x000D_import java.sql.PreparedStatement;
_x000D_import java.sql.ResultSet;
_x000D_import java.sql.SQLException;
_x000D_public class MySQLJDBC {
_x000D_public static void main(String[] args) {
_x000D_// JDBC驅(qū)動(dòng)程序類(lèi)名和數(shù)據(jù)庫(kù)URL
_x000D_final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
_x000D_final String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC";
_x000D_// 數(shù)據(jù)庫(kù)用戶(hù)和密碼
_x000D_final String USER = "root";
_x000D_final String PASS = "password";
_x000D_Connection conn = null;
_x000D_PreparedStatement pstmt = null;
_x000D_ResultSet rs = null;
_x000D_try {
_x000D_// 注冊(cè)JDBC驅(qū)動(dòng)程序
_x000D_Class.forName(JDBC_DRIVER);
_x000D_// 打開(kāi)連接
_x000D_System.out.println("連接數(shù)據(jù)庫(kù)...");
_x000D_conn = DriverManager.getConnection(DB_URL, USER, PASS);
_x000D_// 執(zhí)行查詢(xún)
_x000D_System.out.println("創(chuàng)建PreparedStatement對(duì)象...");
_x000D_String sql = "SELECT id, name, age FROM users WHERE id = ?";
_x000D_pstmt = conn.prepareStatement(sql);
_x000D_pstmt.setInt(1, 1);
_x000D_rs = pstmt.executeQuery();
_x000D_// 處理結(jié)果集
_x000D_while (rs.next()) {
_x000D_int id = rs.getInt("id");
_x000D_String name = rs.getString("name");
_x000D_int age = rs.getInt("age");
_x000D_System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
_x000D_}
_x000D_} catch (ClassNotFoundException e) {
_x000D_e.printStackTrace();
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_} finally {
_x000D_try {
_x000D_if (rs != null) {
_x000D_rs.close();
_x000D_}
_x000D_if (pstmt != null) {
_x000D_pstmt.close();
_x000D_}
_x000D_if (conn != null) {
_x000D_conn.close();
_x000D_}
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_}
_x000D_}
_x000D_}
_x000D_ _x000D_在上面的代碼中，我們首先創(chuàng)建了一個(gè)PreparedStatement對(duì)象。然后，使用setInt()方法設(shè)置查詢(xún)參數(shù)，并使用executeQuery()方法執(zhí)行查詢(xún)語(yǔ)句。在while循環(huán)中處理結(jié)果集。
_x000D_常見(jiàn)問(wèn)題解答
_x000D_1. 如何處理MySQL中的日期和時(shí)間？
_x000D_在Java中，可以使用java.sql.Date和java.sql.Timestamp類(lèi)來(lái)處理MySQL中的日期和時(shí)間。java.sql.Date類(lèi)表示日期（年月日），而java.sql.Timestamp類(lèi)表示日期和時(shí)間（年月日時(shí)分秒）。
_x000D_以下是使用java.sql.Date和java.sql.Timestamp類(lèi)處理MySQL中的日期和時(shí)間的示例代碼：
_x000D_`java
_x000D_import java.sql.Connection;
_x000D_import java.sql.DriverManager;
_x000D_import java.sql.PreparedStatement;
_x000D_import java.sql.ResultSet;
_x000D_import java.sql.SQLException;
_x000D_import java.sql.Timestamp;
_x000D_public class MySQLJDBC {
_x000D_public static void main(String[] args) {
_x000D_// JDBC驅(qū)動(dòng)程序類(lèi)名和數(shù)據(jù)庫(kù)URL
_x000D_final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
_x000D_final String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC";
_x000D_// 數(shù)據(jù)庫(kù)用戶(hù)和密碼
_x000D_final String USER = "root";
_x000D_final String PASS = "password";
_x000D_Connection conn = null;
_x000D_PreparedStatement pstmt = null;
_x000D_ResultSet rs = null;
_x000D_try {
_x000D_// 注冊(cè)JDBC驅(qū)動(dòng)程序
_x000D_Class.forName(JDBC_DRIVER);
_x000D_// 打開(kāi)連接
_x000D_System.out.println("連接數(shù)據(jù)庫(kù)...");
_x000D_conn = DriverManager.getConnection(DB_URL, USER, PASS);
_x000D_// 執(zhí)行查詢(xún)
_x000D_System.out.println("創(chuàng)建PreparedStatement對(duì)象...");
_x000D_String sql = "SELECT id, name, birthday, created_time FROM users WHERE id = ?";
_x000D_pstmt = conn.prepareStatement(sql);
_x000D_pstmt.setInt(1, 1);
_x000D_rs = pstmt.executeQuery();
_x000D_// 處理結(jié)果集
_x000D_while (rs.next()) {
_x000D_int id = rs.getInt("id");
_x000D_String name = rs.getString("name");
_x000D_Date birthday = rs.getDate("birthday");
_x000D_Timestamp createdTime = rs.getTimestamp("created_time");
_x000D_System.out.println("ID: " + id + ", Name: " + name + ", Birthday: " + birthday + ", Created Time: " + createdTime);
_x000D_}
_x000D_} catch (ClassNotFoundException e) {
_x000D_e.printStackTrace();
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_} finally {
_x000D_try {
_x000D_if (rs != null) {
_x000D_rs.close();
_x000D_}
_x000D_if (pstmt != null) {
_x000D_pstmt.close();
_x000D_}
_x000D_if (conn != null) {
_x000D_conn.close();
_x000D_}
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_}
_x000D_}
_x000D_}
_x000D_ _x000D_在上面的代碼中，我們使用java.sql.Date類(lèi)獲取MySQL中的日期，并使用java.sql.Timestamp類(lèi)獲取MySQL中的日期和時(shí)間。
_x000D_2. 如何處理MySQL中的NULL值？
_x000D_在Java中，可以使用ResultSet對(duì)象的wasNull()方法判斷MySQL中的字段是否為NULL。如果字段為NULL，則wasNull()方法返回true，否則返回false。
_x000D_以下是使用wasNull()方法處理MySQL中的NULL值的示例代碼：
_x000D_`java
_x000D_import java.sql.Connection;
_x000D_import java.sql.DriverManager;
_x000D_import java.sql.PreparedStatement;
_x000D_import java.sql.ResultSet;
_x000D_import java.sql.SQLException;
_x000D_public class MySQLJDBC {
_x000D_public static void main(String[] args) {
_x000D_// JDBC驅(qū)動(dòng)程序類(lèi)名和數(shù)據(jù)庫(kù)URL
_x000D_final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
_x000D_final String DB_URL = "jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=UTC";
_x000D_// 數(shù)據(jù)庫(kù)用戶(hù)和密碼
_x000D_final String USER = "root";
_x000D_final String PASS = "password";
_x000D_Connection conn = null;
_x000D_PreparedStatement pstmt = null;
_x000D_ResultSet rs = null;
_x000D_try {
_x000D_// 注冊(cè)JDBC驅(qū)動(dòng)程序
_x000D_Class.forName(JDBC_DRIVER);
_x000D_// 打開(kāi)連接
_x000D_System.out.println("連接數(shù)據(jù)庫(kù)...");
_x000D_conn = DriverManager.getConnection(DB_URL, USER, PASS);
_x000D_// 執(zhí)行查詢(xún)
_x000D_System.out.println("創(chuàng)建PreparedStatement對(duì)象...");
_x000D_String sql = "SELECT id, name, age, email FROM users WHERE id = ?";
_x000D_pstmt = conn.prepareStatement(sql);
_x000D_pstmt.setInt(1, 2);
_x000D_rs = pstmt.executeQuery();
_x000D_// 處理結(jié)果集
_x000D_while (rs.next()) {
_x000D_int id = rs.getInt("id");
_x000D_String name = rs.getString("name");
_x000D_int age = rs.getInt("age");
_x000D_String email = rs.getString("email");
_x000D_if (rs.wasNull()) {
_x000D_email = "NULL";
_x000D_}
_x000D_System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age + ", Email: " + email);
_x000D_}
_x000D_} catch (ClassNotFoundException e) {
_x000D_e.printStackTrace();
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_} finally {
_x000D_try {
_x000D_if (rs != null) {
_x000D_rs.close();
_x000D_}
_x000D_if (pstmt != null) {
_x000D_pstmt.close();
_x000D_}
_x000D_if (conn != null) {
_x000D_conn.close();
_x000D_}
_x000D_} catch (SQLException e) {
_x000D_e.printStackTrace();
_x000D_}
_x000D_}
_x000D_}
_x000D_ _x000D_在上面的代碼中，我們使用wasNull()方法判斷MySQL中的email字段是否為NULL。如果為NULL，則將其賦值為字符串"NULL"。
_x000D_本文介紹了如何使用Java查詢(xún)MySQL數(shù)據(jù)庫(kù)。我們首先需要連接數(shù)據(jù)庫(kù)，然后使用Statement或PreparedStatement對(duì)象執(zhí)行查詢(xún)。本文還解答了一些常見(jiàn)問(wèn)題，如如何處理MySQL中的日期和時(shí)間、如何處理MySQL中的NULL值等。通過(guò)本文的學(xué)習(xí)，相信讀者已經(jīng)掌握了Java查詢(xún)MySQL數(shù)據(jù)庫(kù)的基本方法。
_x000D_
京公網(wǎng)安備 11010802030320號(hào)