使用SQLiteJDBC和HikariCP实现Java程序连接SQLite数据库

为了在 Java 程序中连接 SQLite 数据库并进行高效的数据库操作，可以使用 SQLiteJDBC 和 HikariCP 这两个强大的工具。SQLiteJDBC 是一个用于连接 SQLite 数据库的 JDBC 驱动程序，而 HikariCP 则是一个高性能的数据库连接池库。

### 添加依赖
首先，在项目的 `pom.xml` 文件中添加以下依赖：

```xml


org.xerial
sqlite-jdbc
3.32.3.2


com.zaxxer
HikariCP
3.4.5


```

### 代码示例
接下来是完整的 Java 代码示例，演示如何使用 HikariCP 连接 SQLite 数据库并执行基本的 CRUD 操作。

```java
package com.example;

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.Date;

public class SQLiteTest {
public static void main(String[] args) {
SQLiteTest.testSQLite();
}

private static void testSQLite() {
Connection cOnnection= null;
Statement statement = null;
ResultSet resultSet = null;
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss:SSS");
int taskId = 1;
long modifyTime = 852336000000L;
String srcIp = "192.168.0.101";
String dstIp = "192.168.0.102";
long fileSize = 10240L;
String syncDirection = "DIRECTION_INT2EXT";
String filePath = "look.txt";

try {
// 使用HikariCP数据库连接池
HikariConfig hikariCOnfig= new HikariConfig();
hikariConfig.setPoolName("SQLiteConnectionPool");
hikariConfig.setDriverClassName("org.sqlite.JDBC");
hikariConfig.setJdbcUrl("jdbc:sqlite:D:\work\software\SQLite\fileSyncLog.db");
hikariConfig.setAutoCommit(false);
hikariConfig.setMinimumIdle(8);
hikariConfig.setMaximumPoolSize(32);
HikariDataSource dataSource = new HikariDataSource(hikariConfig);
cOnnection= dataSource.getConnection();

statement = connection.createStatement();
// 判断表是否存在
resultSet = connection.getMetaData().getTables(null, null, "fileSyncLog", null);
if (!resultSet.next()) {
System.out.println(simpleDateFormat.format(new Date()) + ", 创建表并添加数据！");
// 创建表
statement.executeUpdate("CREATE TABLE fileSyncLog (task_id INTEGER, modify_time LONG, src_ip TEXT, dst_ip TEXT, sync_result INTEGER, file_size LONG, sync_direction TEXT, file_name TEXT); ");
// 向表中添加数据
for (int i = 1; i <= 10; i++) {
statement.executeUpdate("INSERT INTO fileSyncLog VALUES (" + i + ", " + modifyTime + ", '" + srcIp + '", '" + dstIp + '", 1, " + fileSize + ", '" + syncDirection + '", '" + filePath + "');");
}
System.out.println(simpleDateFormat.format(new Date()) + ", 数据添加成功！");
}

// 提交SQL
connection.commit();
// 得到结果集
resultSet = statement.executeQuery("SELECT * FROM fileSyncLog;");
while (resultSet.next()) {
if (resultSet.getInt("task_id") == taskId && resultSet.getLong("modify_time") == modifyTime && resultSet.getString("src_ip").equals(srcIp) && resultSet.getString("dst_ip").equals(dstIp) && resultSet.getInt("sync_result") == 1 && resultSet.getLong("file_size") == fileSize && resultSet.getString("sync_direction").equals(syncDirection) && resultSet.getString("file_name").equals(filePath)) {
System.out.println(simpleDateFormat.format(new Date()) + ", task_id = " + resultSet.getString("task_id") + ", file_name = " + resultSet.getString("file_name"));
}
}

resultSet = statement.executeQuery("SELECT * FROM fileSyncLog WHERE task_id=" + taskId + " AND modify_time=" + modifyTime + " AND src_ip='" + srcIp + "' AND dst_ip='" + dstIp + "' AND file_size=" + fileSize + " AND sync_direction='" + syncDirection + "' AND file_name='" + filePath + "';");
while (resultSet.next()) {
System.out.println(simpleDateFormat.format(new Date()) + ", task_id = " + resultSet.getString("task_id") + ", file_name = " + resultSet.getString("file_name"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (statement != null) statement.close();
if (resultSet != null) resultSet.close();
if (connection != null) connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
```

### 总结
通过上述代码，我们展示了如何使用 SQLiteJDBC 和 HikariCP 在 Java 程序中连接 SQLite 数据库，并执行创建表、插入数据、查询数据等操作。HikariCP 的使用显著提高了数据库连接的效率和性能，使其成为处理大量数据库操作的理想选择。