Java中連接數(shù)據(jù)庫方式詳細(xì)步驟記錄

更新時間：2025年01月08日 11:05:50 作者：噢小程

這篇文章主要介紹了Java中連接數(shù)據(jù)庫方式的詳細(xì)步驟,包括添加依賴、建立連接、執(zhí)行SQL語句、處理結(jié)果集和關(guān)閉連接,還討論了數(shù)據(jù)庫連接池的使用,需要的朋友可以參考下

一、JDBC（Java Database Connectivity）

這是 Java 連接數(shù)據(jù)庫最基本的方式。

導(dǎo)入數(shù)據(jù)庫驅(qū)動：首先需要將特定數(shù)據(jù)庫的 JDBC 驅(qū)動添加到項目的依賴中。
加載驅(qū)動：使用Class.forName()方法加載數(shù)據(jù)庫驅(qū)動。例如，Class.forName("com.mysql.cj.jdbc.Driver");。
建立連接：使用DriverManager.getConnection()方法建立與數(shù)據(jù)庫的連接。例如，String url = "jdbc:mysql://localhost:3306/mydb";，String username = "root";，String password = "password";，Connection connection = DriverManager.getConnection(url, username, password);。
執(zhí)行 SQL 語句：通過Statement或PreparedStatement對象執(zhí)行 SQL 查詢、插入、更新或刪除等操作。
處理結(jié)果集：如果是查詢操作，需要處理返回的ResultSet結(jié)果集。
關(guān)閉連接：在操作完成后，務(wù)必關(guān)閉連接、語句和結(jié)果集以釋放資源。

1、添加依賴

確定數(shù)據(jù)庫類型：首先確定你要連接的數(shù)據(jù)庫類型，比如 MySQL、Oracle、SQL Server 等。不同的數(shù)據(jù)庫需要不同的 JDBC 驅(qū)動。
添加依賴：將相應(yīng)數(shù)據(jù)庫的 JDBC 驅(qū)動添加到你的項目中。如果是 Maven 項目，可以在pom.xml文件中添加依賴；如果是 Gradle 項目，則在build.gradle文件中添加。例如，對于 MySQL 數(shù)據(jù)庫，可以添加mysql-connector-java依賴。

2、連接數(shù)據(jù)庫

Java 虛擬機能夠找到并加載特定數(shù)據(jù)庫的 JDBC 驅(qū)動程序

try {
       Class.forName("com.mysql.cj.jdbc.Driver");
   } catch (ClassNotFoundException e) {
       e.printStackTrace();
   }

3、建立連接

url是數(shù)據(jù)庫的連接字符串，其中localhost是數(shù)據(jù)庫服務(wù)器地址，3306是 MySQL 的默認(rèn)端口號，your_database_name是你要連接的數(shù)據(jù)庫名稱。
username和password分別是數(shù)據(jù)庫的用戶名和密碼。

String url = "jdbc:mysql://localhost:3306/your_database_name";
   String username = "your_username";
   String password = "your_password";
   try {
       Connection connection = DriverManager.getConnection(url, username, password);
       // 連接成功后可以進行后續(xù)數(shù)據(jù)庫操作
   } catch (SQLException e) {
       e.printStackTrace();
   }

4、執(zhí)行 SQL 語句

可以使用Statement或PreparedStatement來執(zhí)行 SQL 語句。

Statement示例：

try {
         Statement statement = connection.createStatement();
         ResultSet resultSet = statement.executeQuery("SELECT * FROM your_table_name");
         while (resultSet.next()) {
             // 處理結(jié)果集
             int id = resultSet.getInt("id");
             String name = resultSet.getString("name");
             System.out.println("ID: " + id + ", Name: " + name);
         }
     } catch (SQLException e) {
         e.printStackTrace();
     }

若使用PreparedStatement，（可以防止 SQL 注入）：

try {
         String sql = "SELECT * FROM your_table_name WHERE id =?";
         PreparedStatement preparedStatement = connection.prepareStatement(sql);
         preparedStatement.setInt(1, 123); // 設(shè)置參數(shù)值
         ResultSet resultSet = preparedStatement.executeQuery();
         while (resultSet.next()) {
             // 處理結(jié)果集
             int id = resultSet.getInt("id");
             String name = resultSet.getString("name");
             System.out.println("ID: " + id + ", Name: " + name);
         }
     } catch (SQLException e) {
         e.printStackTrace();
     }

5、處理結(jié)果集

根據(jù)執(zhí)行的 SQL 語句類型（查詢、插入、更新、刪除等），處理結(jié)果集的方式不同。

對于查詢語句，使用ResultSet的方法（如getInt、getString等）獲取結(jié)果集中的列值。

1）查詢語句處理

使用ResultSet遍歷結(jié)果集：

- 當(dāng)執(zhí)行查詢語句后，會得到一個ResultSet對象，它代表了從數(shù)據(jù)庫返回的結(jié)果集?？梢允褂?code>while循環(huán)結(jié)合ResultSet.next()方法來遍歷結(jié)果集中的每一行數(shù)據(jù)。
- 例如：

try {
         Statement statement = connection.createStatement();
         ResultSet resultSet = statement.executeQuery("SELECT * FROM your_table_name");
         while (resultSet.next()) {
             // 處理每一行數(shù)據(jù)
             int id = resultSet.getInt("id");
             String name = resultSet.getString("name");
             System.out.println("ID: " + id + ", Name: " + name);
         }
     } catch (SQLException e) {
         e.printStackTrace();
     }

在循環(huán)中，可以根據(jù)列名或者列索引，使用ResultSet的相應(yīng)方法（如getInt、getString、getDouble等）來獲取每一列的值。列索引從 1 開始。
獲取特定類型的數(shù)據(jù)：
- 根據(jù)數(shù)據(jù)庫中列的數(shù)據(jù)類型，選擇合適的ResultSet方法來獲取值。
- 例如，如果列是整數(shù)類型，可以使用getInt；如果是字符串類型，可以使用getString；如果是浮點數(shù)類型，可以使用getDouble等。
- 同時，可以傳入列名或者列索引作為參數(shù)。例如：

int id = resultSet.getInt(1); // 通過列索引獲取第一列的值（整數(shù)類型）
     String name = resultSet.getString("name"); // 通過列名獲取名為"name"的列的值（字符串類型）

2）插入語句處理

執(zhí)行插入語句后，通?？梢垣@取插入行的自增主鍵值（如果數(shù)據(jù)庫表有自增主鍵）：

- 使用PreparedStatement執(zhí)行插入語句，并設(shè)置返回自增主鍵的參數(shù)。
- 例如：

String sql = "INSERT INTO your_table_name (column1, column2) VALUES (?,?)";
     try {
         PreparedStatement preparedStatement = connection.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
         preparedStatement.setString(1, "value1");
         preparedStatement.setString(2, "value2");
         int rowsInserted = preparedStatement.executeUpdate();
         if (rowsInserted > 0) {
             // 獲取自增主鍵
             ResultSet generatedKeys = preparedStatement.getGeneratedKeys();
             if (generatedKeys.next()) {
                 int generatedId = generatedKeys.getInt(1);
                 System.out.println("Inserted row with id: " + generatedId);
             }
         }
     } catch (SQLException e) {
         e.printStackTrace();
     }

在執(zhí)行插入操作后，通過PreparedStatement.getGeneratedKeys()方法可以獲取包含自增主鍵值的ResultSet，然后可以從這個結(jié)果集中獲取插入行的主鍵值。

3）更新語句處理

執(zhí)行更新語句后，通常會返回受影響的行數(shù)：

- 使用Statement或PreparedStatement執(zhí)行更新語句，然后通過executeUpdate方法的返回值來判斷有多少行被更新。
- 例如：

String sql = "UPDATE your_table_name SET column1 =? WHERE column2 =?";
     try {
         PreparedStatement preparedStatement = connection.prepareStatement(sql);
         preparedStatement.setString(1, "newValue1");
         preparedStatement.setString(2, "conditionValue");
         int rowsUpdated = preparedStatement.executeUpdate();
         System.out.println("Updated " + rowsUpdated + " rows.");
     } catch (SQLException e) {
         e.printStackTrace();
     }

如果返回值大于 0，表示有行被更新；如果返回值為 0，表示沒有滿足條件的行被更新。

4）刪除語句處理

與更新語句類似，執(zhí)行刪除語句后也會返回受影響的行數(shù)：

- 使用Statement或PreparedStatement執(zhí)行刪除語句，然后通過executeUpdate方法的返回值來判斷有多少行被刪除。
- 例如：

String sql = "DELETE FROM your_table_name WHERE column1 =?";
     try {
         PreparedStatement preparedStatement = connection.prepareStatement(sql);
         preparedStatement.setString(1, "valueToDelete");
         int rowsDeleted = preparedStatement.executeUpdate();
         System.out.println("Deleted " + rowsDeleted + " rows.");
     } catch (SQLException e) {
         e.printStackTrace();
     }

如果返回值大于 0，表示有行被刪除；如果返回值為 0，表示沒有滿足條件的行被刪除。

在處理這些 SQL 語句時，需要注意捕獲SQLException異常，以確保在出現(xiàn)數(shù)據(jù)庫錯誤時能夠正確處理異常情況，并進行適當(dāng)?shù)腻e誤處理和日志記錄。

6、關(guān)閉連接

在完成數(shù)據(jù)庫操作后，務(wù)必關(guān)閉連接以釋放資源。

try {
       if (connection!= null) {
           connection.close();
       }
   } catch (SQLException e) {
       e.printStackTrace();
   }

二、數(shù)據(jù)庫連接池

使用數(shù)據(jù)庫連接池可以提高數(shù)據(jù)庫連接的性能和效率，常見的數(shù)據(jù)庫連接池有 HikariCP、C3P0、Druid 等。

以 Druid 為例，首先添加 Druid 的依賴到項目中，配置連接池參數(shù)，如數(shù)據(jù)庫 URL、用戶名、密碼、最大連接數(shù)等，通過連接池獲取數(shù)據(jù)庫連接進行操作。

1、添加依賴

如果是 Maven 項目，在pom.xml中添加以下依賴：

<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.12</version>
</dependency>

如果是 Gradle 項目，在build.gradle中添加：

implementation 'com.alibaba:druid:1.2.12'

2、基本使用步驟

1）配置數(shù)據(jù)源：

import com.alibaba.druid.pool.DruidDataSource;

   public class DruidExample {
       public static void main(String[] args) {
           // 創(chuàng)建 Druid 數(shù)據(jù)源對象
           DruidDataSource dataSource = new DruidDataSource();
           dataSource.setUrl("jdbc:mysql://localhost:3306/your_database");
           dataSource.setUsername("your_username");
           dataSource.setPassword("your_password");
           // 可以設(shè)置其他屬性，如最大連接數(shù)、最小連接數(shù)等
           dataSource.setInitialSize(5);
           dataSource.setMaxActive(10);
       }
   }

2）獲取數(shù)據(jù)庫連接：

try {
       Connection connection = dataSource.getConnection();
       // 使用連接進行數(shù)據(jù)庫操作
   } catch (SQLException e) {
       e.printStackTrace();
   }

3）關(guān)閉數(shù)據(jù)源（通常在應(yīng)用程序關(guān)閉時執(zhí)行）

dataSource.close();

3、監(jiān)控功能

Druid 提供了強大的監(jiān)控功能，可以通過以下方式訪問監(jiān)控頁面：

在應(yīng)用程序中配置 Druid 的監(jiān)控屬性：

dataSource.setFilters("stat");
   dataSource.setEnable(true);

訪問監(jiān)控頁面：默認(rèn)情況下，可以通過http://localhost:8080/druid/index.html訪問 Druid 的監(jiān)控頁面，前提是你的應(yīng)用程序在端口 8080 運行。在監(jiān)控頁面中，可以查看連接池的狀態(tài)、SQL 執(zhí)行情況等信息。

4、結(jié)合 Spring 使用

如果在 Spring 項目中使用 Druid，可以通過以下步驟進行配置：

在配置文件中配置數(shù)據(jù)源：

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
       <property name="url" value="jdbc:mysql://localhost:3306/your_database"/>
       <property name="username" value="your_username"/>
       <property name="password" value="your_password"/>
       <!-- 其他屬性配置 -->
   </bean>

在代碼中通過@Autowired注入數(shù)據(jù)源：

import javax.sql.DataSource;

   @Service
   public class YourService {
       private DataSource dataSource;

       @Autowired
       public YourService(DataSource dataSource) {
           this.dataSource = dataSource;
       }

       public void doSomethingWithDatabase() {
           try {
               Connection connection = dataSource.getConnection();
               // 進行數(shù)據(jù)庫操作
           } catch (SQLException e) {
               e.printStackTrace();
           }
       }
   }

三、ORM框架

Hibernate：Hibernate 是一個強大的 ORM 框架，它允許將數(shù)據(jù)庫表映射為 Java 對象，簡化了數(shù)據(jù)庫操作。通過配置 Hibernate 的配置文件和實體類的映射文件，可以輕松地連接到數(shù)據(jù)庫并進行各種數(shù)據(jù)庫操作。
MyBatis：MyBatis 也是一種常用的數(shù)據(jù)庫訪問框架，它通過 SQL 映射文件將 SQL 語句與 Java 方法進行映射。雖然 MyBatis 不是嚴(yán)格意義上的 ORM 框架，但它提供了一種方便的方式來操作數(shù)據(jù)庫，同時也允許編寫自定義 SQL 語句以滿足復(fù)雜的業(yè)務(wù)需求。

這里以MyBatis舉例：

1、添加依賴

如果是 Maven 項目，在pom.xml中添加以下依賴：

<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis</artifactId>
    <version>3.5.10</version>
</dependency>

如果是 Gradle 項目，在build.gradle中添加：

implementation 'org.mybatis:mybatis:3.5.10'

同時，如果使用數(shù)據(jù)庫，還需要添加相應(yīng)數(shù)據(jù)庫的驅(qū)動依賴。

2、創(chuàng)建實體類

例如，有一個用戶實體類：

public class User {
    private int id;
    private String username;
    private String password;

    // 構(gòu)造函數(shù)、getter 和 setter 方法
}

3、創(chuàng)建映射接口

import java.util.List;

public interface UserMapper {
    List<User> getAllUsers();
    User getUserById(int id);
    void insertUser(User user);
    void updateUser(User user);
    void deleteUser(int id);
}

4、編寫 SQL 映射文件

創(chuàng)建一個與映射接口同名的 XML 文件，例如UserMapper.xml：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="your.package.name.UserMapper">

    <select id="getAllUsers" resultType="User">
        SELECT * FROM users;
    </select>

    <select id="getUserById" parameterType="int" resultType="User">
        SELECT * FROM users WHERE id = #{id};
    </select>

    <insert id="insertUser" parameterType="User">
        INSERT INTO users (username, password) VALUES (#{username}, #{password});
    </insert>

    <update id="updateUser" parameterType="User">
        UPDATE users SET username = #{username}, password = #{password} WHERE id = #{id};
    </update>

    <delete id="deleteUser" parameterType="int">
        DELETE FROM users WHERE id = #{id};
    </delete>

</mapper>

5、配置 MyBatis

創(chuàng)建mybatis-config.xml配置文件：

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <environments default="development">
        <environment id="development">
            <transactionManager type="JDBC"/>
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/your_database"/>
                <property name="username" value="your_username"/>
                <property name="password" value="your_password"/>
            </dataSource>
        </environment>
    </environments>
    <mappers>
        <mapper resource="your/package/name/UserMapper.xml"/>
    </mappers>
</configuration>

在代碼中加載配置文件并使用 MyBatis：

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;
import java.io.InputStream;

public class MyBatisExample {
    public static void main(String[] args) {
        String resource = "mybatis-config.xml";
        InputStream inputStream = null;
        try {
            inputStream = Resources.getResourceAsStream(resource);
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
            SqlSession sqlSession = sqlSessionFactory.openSession();

            // 獲取映射接口的實現(xiàn)
            UserMapper userMapper = sqlSession.getMapper(UserMapper.class);

            // 查詢所有用戶
            List<User> users = userMapper.getAllUsers();
            for (User user : users) {
                System.out.println(user.getId() + ", " + user.getUsername() + ", " + user.getPassword());
            }

            // 插入用戶
            User newUser = new User();
            newUser.setUsername("newUser");
            newUser.setPassword("newPassword");
            userMapper.insertUser(newUser);
            sqlSession.commit();

            // 根據(jù) ID 查詢用戶
            User userById = userMapper.getUserById(1);
            System.out.println(userById.getId() + ", " + userById.getUsername() + ", " + userById.getPassword());

            // 更新用戶
            User userToUpdate = userMapper.getUserById(2);
            userToUpdate.setUsername("updatedUser");
            userMapper.updateUser(userToUpdate);
            sqlSession.commit();

            // 刪除用戶
            userMapper.deleteUser(3);
            sqlSession.commit();

            sqlSession.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

總結(jié)

到此這篇關(guān)于Java中連接數(shù)據(jù)庫方式詳細(xì)步驟的文章就介紹到這了,更多相關(guān)Java連接數(shù)據(jù)庫方式內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java中連接數(shù)據(jù)庫方式詳細(xì)步驟記錄

目錄

一、JDBC（Java Database Connectivity）

1、添加依賴

2、連接數(shù)據(jù)庫

3、建立連接

4、執(zhí)行 SQL 語句

5、處理結(jié)果集

1）查詢語句處理

2）插入語句處理

3）更新語句處理

4）刪除語句處理

6、關(guān)閉連接

二、數(shù)據(jù)庫連接池

1、添加依賴

2、基本使用步驟

1）配置數(shù)據(jù)源：

2）獲取數(shù)據(jù)庫連接：

3）關(guān)閉數(shù)據(jù)源（通常在應(yīng)用程序關(guān)閉時執(zhí)行）

3、監(jiān)控功能

4、結(jié)合 Spring 使用

三、ORM框架

1、添加依賴

2、創(chuàng)建實體類

3、創(chuàng)建映射接口

4、編寫 SQL 映射文件

5、配置 MyBatis

總結(jié)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java中連接數(shù)據(jù)庫方式詳細(xì)步驟記錄

目錄

一、JDBC（Java Database Connectivity）

1、添加依賴

2、連接數(shù)據(jù)庫

3、建立連接

4、執(zhí)行 SQL 語句

5、處理結(jié)果集

1）查詢語句處理

2）插入語句處理

3）更新語句處理

4）刪除語句處理

6、關(guān)閉連接

二、數(shù)據(jù)庫連接池

1、添加依賴

2、基本使用步驟

1）配置數(shù)據(jù)源：

2）獲取數(shù)據(jù)庫連接：

3）關(guān)閉數(shù)據(jù)源（通常在應(yīng)用程序關(guān)閉時執(zhí)行）

3、監(jiān)控功能

4、結(jié)合 Spring 使用

三、ORM框架

1、添加依賴

2、創(chuàng)建實體類

3、創(chuàng)建映射接口

4、編寫 SQL 映射文件

5、配置 MyBatis

總結(jié)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

一、JDBC（Java Database Connectivity）

1、添加依賴

4、執(zhí)行 SQL 語句

6、關(guān)閉連接

二、數(shù)據(jù)庫連接池

1、添加依賴

2、基本使用步驟

3、監(jiān)控功能

4、結(jié)合 Spring 使用

三、ORM框架

2、創(chuàng)建實體類

4、編寫 SQL 映射文件

5、配置 MyBatis