使用Java連接數據庫

隨着互聯網的發展，數據的存儲和處理變得越來越重要，因此學習如何使用Java連接數據庫也變得越來越重要。Java是一種廣泛使用的編程語言，具有跨平台性和易於學習的特點，同時也可以方便地連接數據庫。

一、連接關係型數據庫

Java可以與大多數關係型數據庫進行連接，如Oracle、MySQL、PostgreSQL等。下面以MySQL為例介紹Java如何連接數據庫。

首先需要下載該數據庫的驅動程序，並將其添加到Java項目的類路徑中。

Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3306/database";
Connection conn = DriverManager.getConnection(url,"root","password");

在代碼中，首先使用Class.forName()方法加載MySQL的驅動程序，在連接字符串中指定連接的數據庫和端口號。使用DriverManager.getConnection()方法連接數據庫，並指定用戶名和密碼。

連接數據庫成功後，可以通過Connection對象執行SQL語句。

Statement stmt = conn.createStatement();
String sql = "SELECT * FROM users;";
ResultSet rs = stmt.executeQuery(sql);
while(rs.next()){
    System.out.println(rs.getString("name"));
}

在以上代碼中，使用Connection.createStatement()方法創建Statement對象，使用executeQuery()方法執行SQL查詢，並使用ResultSet遍歷結果集。

二、連接非關係型數據庫

除了關係型數據庫，Java還可以連接非關係型數據庫，如MongoDB、Redis、Cassandra等。

下面以MongoDB為例介紹Java如何連接非關係型數據庫。

首先需要下載該數據庫的驅動程序，並將其添加到Java項目的類路徑中。

ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
Properties properties = new Properties();
properties.load(classLoader.getResourceAsStream("mongo.properties"));
String host = properties.getProperty("host");
int port = Integer.parseInt(properties.getProperty("port"));
String databaseName = properties.getProperty("databaseName");

MongoClient mongoClient = new MongoClient(host, port);

MongoDatabase database = mongoClient.getDatabase(databaseName);

MongoCollection<Document> collection = database.getCollection("users");

FindIterable<Document> iterable = collection.find();

for(Document document : iterable) {
   System.out.println(document.toJson());
}

在以上代碼中，通過加載屬性文件的方式獲取MongoDB的連接信息，並創建MongoClient連接。獲取MongoDatabase對象和MongoCollection對象，使用find()方法查詢文檔，並使用Document.toJson()方法將結果轉化為JSON格式輸出。

三、連接池技術

連接池技術是一種提高數據庫連接利用率的技術，通過提前創建連接對象，並將其存儲在連接池中等待重用，避免了重複創建連接對象的性能開銷。

下面以Druid連接池為例介紹Java如何使用連接池技術。

首先需要將Druid的依賴添加到項目中。

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

在代碼中，使用DruidDataSource創建連接池對象，設置連接池的屬性，並通過getConnection()方法獲取連接對象。

//創建dataSource
DruidDataSource dataSource = new DruidDataSource();
dataSource.setDbType("mysql");
dataSource.setUrl("jdbc:mysql://localhost:3306/database");
dataSource.setUsername("root");
dataSource.setPassword("password");

//獲取連接對象
Connection conn = dataSource.getConnection();

在以上代碼中，通過設置數據源的URL、用戶名和密碼等信息，使用dataSource.getConnection()方法獲取連接對象，使用完畢後需要調用conn.close()方法歸還連接池對象。

代碼示例

完整的Java連接數據庫的代碼示例如下：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import com.alibaba.druid.pool.DruidDataSource;
import com.mongodb.MongoClient;
import com.mongodb.client.FindIterable;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;

public class ConnectionDemo {
    //連接MySQL數據庫
    public void mysqlConnectionDemo() throws ClassNotFoundException, SQLException {
        Class.forName("com.mysql.jdbc.Driver");
        String url = "jdbc:mysql://localhost:3306/database";
        Connection conn = DriverManager.getConnection(url,"root","password");

        Statement stmt = conn.createStatement();
        String sql = "SELECT * FROM users;";
        ResultSet rs = stmt.executeQuery(sql);
        while(rs.next()){
            System.out.println(rs.getString("name"));
        }

        conn.close();
    }

    //連接MongoDB數據庫
    public void mongoConnectionDemo() throws Exception {
        ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
        Properties properties = new Properties();
        properties.load(classLoader.getResourceAsStream("mongo.properties"));
        String host = properties.getProperty("host");
        int port = Integer.parseInt(properties.getProperty("port"));
        String databaseName = properties.getProperty("databaseName");

        MongoClient mongoClient = new MongoClient(host, port);

        MongoDatabase database = mongoClient.getDatabase(databaseName);

        MongoCollection collection = database.getCollection("users");

        FindIterable iterable = collection.find();

        for(Document document : iterable) {
            System.out.println(document.toJson());
        }

        mongoClient.close();
    }

    //使用Druid連接池連接MySQL數據庫
    public void druidConnectionDemo() throws SQLException {
        //創建dataSource
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDbType("mysql");
        dataSource.setUrl("jdbc:mysql://localhost:3306/database");
        dataSource.setUsername("root");
        dataSource.setPassword("password");

        //獲取連接對象
        Connection conn = dataSource.getConnection();

        conn.close();
    }
}

總結

本文從連接關係型數據庫、連接非關係型數據庫、連接池技術三個方面詳細介紹了如何使用Java連接數據庫，並提供了相應的代碼示例。Java連接數據庫是Java開發中的一個重要知識點，對於提高應用的性能和穩定性具有重要作用。