Java连接数据库：SQLAlchemy和JDBC使用示例

原创以你之姓@ 2024-10-22 12:15 154阅读 0赞

在Java中，我们可以使用两种方式来连接数据库：SQLAlchemy和JDBC。这里分别给出这两种方法的使用示例。

1. **SQLAlchemy** (推荐于Spring Boot等现代框架)

- 首先需要引入依赖：

```java
// pom.xml 或者 Spring Boot 的配置类
<dependency>
    <groupId>org.sqlalchemy</groupId>
    <artifactId>sqlalchemy-jdbc-url</artifactId>
    <version>4.3.18</version>
</dependency>
```

- 创建数据库连接：

```java
import org.sqlalchemy.Connection;
import org.sqlalchemy.DriverManager;
import org.sqlalchemy.util.Properties;

public class SqlAlchemyExample {
    private static final String DATABASE_URL = "jdbc:mysql://localhost:3306/mydatabase";
    
    public static Connection connectToDatabase() {
        Properties connectionProperties = new Properties();
        
        // Set the database URL
        connectionProperties.setProperty("url", DATABASE_URL);

// Load the JDBC driver (if not already loaded)
        try (Class.forName("com.mysql.jdbc.Driver")) {}  // MySQL

// Create a connection object
        return DriverManager.getConnection(connectionProperties);
    }

public static void main(String[] args) {
        Connection connection = connectToDatabase();
        
        // Use the connection for database operations
        // ...

// Close the connection when done
        connection.close();
    }
}
```

2. **JDBC** (传统方式)

- 首先需要添加数据库驱动的jar文件到项目中，例如MySQL的：

```java
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.24</version>
</dependency>
```

- 然后编写Java代码连接数据库：

```java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

public class JdbcExample {
    private static final String DATABASE_URL = "jdbc:mysql://localhost:3306/mydatabase";
    
    public static Connection connectToDatabase() throws SQLException {
        // Load the JDBC driver (if not already loaded)
        Class.forName("com.mysql.jdbc.Driver");

// Create a connection object
        return DriverManager.getConnection(DATABASE_URL);
    }

public static void main(String[] args) {
        Connection connection = connectToDatabase();

// Use the connection for database operations
        // ...

// Close the connection when done
        connection.close();
    }
}
```

注意：以上示例中的数据库URL、用户名和密码需要替换为你自己的实际值。