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

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

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

一、JDBC（Java Database Connectivity）

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

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

1、添加依賴

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

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

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

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

3、建立連接

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

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);
       // 連接成功后可以進(jìn)行后續(xù)數(shù)據(jù)庫(kù)操作
   } catch (SQLException e) {
       e.printStackTrace();
   }

4、執(zhí)行 SQL 語(yǔ)句

可以使用Statement或PreparedStatement來(lái)執(zhí)行 SQL 語(yǔ)句。

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 語(yǔ)句類(lèi)型（查詢、插入、更新、刪除等），處理結(jié)果集的方式不同。

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

1）查詢語(yǔ)句處理

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

- 當(dāng)執(zhí)行查詢語(yǔ)句后，會(huì)得到一個(gè)ResultSet對(duì)象，它代表了從數(shù)據(jù)庫(kù)返回的結(jié)果集?？梢允褂?code>while循環(huán)結(jié)合ResultSet.next()方法來(lái)遍歷結(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等）來(lái)獲取每一列的值。列索引從 1 開(kāi)始。
獲取特定類(lèi)型的數(shù)據(jù)：
- 根據(jù)數(shù)據(jù)庫(kù)中列的數(shù)據(jù)類(lèi)型，選擇合適的ResultSet方法來(lái)獲取值。
- 例如，如果列是整數(shù)類(lèi)型，可以使用getInt；如果是字符串類(lèi)型，可以使用getString；如果是浮點(diǎn)數(shù)類(lèi)型，可以使用getDouble等。
- 同時(shí)，可以傳入列名或者列索引作為參數(shù)。例如：

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

2）插入語(yǔ)句處理

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

- 使用PreparedStatement執(zhí)行插入語(yǔ)句，并設(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í)行插入操作后，通過(guò)PreparedStatement.getGeneratedKeys()方法可以獲取包含自增主鍵值的ResultSet，然后可以從這個(gè)結(jié)果集中獲取插入行的主鍵值。

3）更新語(yǔ)句處理

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

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

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，表示沒(méi)有滿足條件的行被更新。

4）刪除語(yǔ)句處理

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

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

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，表示沒(méi)有滿足條件的行被刪除。

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

6、關(guān)閉連接

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

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

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

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

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

1、添加依賴

如果是 Maven 項(xiàng)目，在pom.xml中添加以下依賴：

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

如果是 Gradle 項(xiàng)目，在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ù)源對(duì)象
           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ù)庫(kù)連接：

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

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

dataSource.close();

3、監(jiān)控功能

Druid 提供了強(qiáng)大的監(jiān)控功能，可以通過(guò)以下方式訪問(wèn)監(jiān)控頁(yè)面：

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

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

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

4、結(jié)合 Spring 使用

如果在 Spring 項(xiàng)目中使用 Druid，可以通過(guò)以下步驟進(jìn)行配置：

在配置文件中配置數(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>

在代碼中通過(guò)@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();
               // 進(jìn)行數(shù)據(jù)庫(kù)操作
           } catch (SQLException e) {
               e.printStackTrace();
           }
       }
   }

三、ORM框架

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

這里以MyBatis舉例：

1、添加依賴

如果是 Maven 項(xiàng)目，在pom.xml中添加以下依賴：

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

如果是 Gradle 項(xiàng)目，在build.gradle中添加：

implementation 'org.mybatis:mybatis:3.5.10'

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

2、創(chuàng)建實(shí)體類(lèi)

例如，有一個(gè)用戶實(shí)體類(lèi)：

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、編寫(xiě) SQL 映射文件

創(chuàng)建一個(gè)與映射接口同名的 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();

            // 獲取映射接口的實(shí)現(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ù)庫(kù)方式詳細(xì)步驟的文章就介紹到這了,更多相關(guān)Java連接數(shù)據(jù)庫(kù)方式內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

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

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

目錄

一、JDBC（Java Database Connectivity）

1、添加依賴

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

3、建立連接

4、執(zhí)行 SQL 語(yǔ)句

5、處理結(jié)果集

1）查詢語(yǔ)句處理

2）插入語(yǔ)句處理

3）更新語(yǔ)句處理

4）刪除語(yǔ)句處理

6、關(guān)閉連接

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

1、添加依賴

2、基本使用步驟

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

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

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

3、監(jiān)控功能

4、結(jié)合 Spring 使用

三、ORM框架

1、添加依賴

2、創(chuàng)建實(shí)體類(lèi)

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

4、編寫(xiě) SQL 映射文件

5、配置 MyBatis

總結(jié)

相關(guān)文章

最新評(píng)論

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

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

常用在線小工具

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

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

目錄

一、JDBC（Java Database Connectivity）

1、添加依賴

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

3、建立連接

4、執(zhí)行 SQL 語(yǔ)句

5、處理結(jié)果集

1）查詢語(yǔ)句處理

2）插入語(yǔ)句處理

3）更新語(yǔ)句處理

4）刪除語(yǔ)句處理

6、關(guān)閉連接

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

1、添加依賴

2、基本使用步驟

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

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

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

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

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

三、ORM框架

1、添加依賴

2、創(chuàng)建實(shí)體類(lèi)

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

4、編寫(xiě) SQL 映射文件

5、配置 MyBatis

總結(jié)

相關(guān)文章

最新評(píng)論

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

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

常用在線小工具

1、添加依賴

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

3、建立連接

4、執(zhí)行 SQL 語(yǔ)句

5、處理結(jié)果集

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

1、添加依賴

3、監(jiān)控功能

4、結(jié)合 Spring 使用

三、ORM框架

1、添加依賴

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

5、配置 MyBatis