java - 如何使用java检查sqlite中是否存在与数据库的连接？

Question

我有以下 dbConnection

public class DBConnection {

    protected Statement statement;
    protected Connection connection = null;

    public DBConnection() {
        try {
            Class.forName("org.sqlite.JDBC");
        } catch (ClassNotFoundException e1) {
            e1.printStackTrace();
        }
        try {

            connection = DriverManager.getConnection("jdbc:sqlite:C:\\Users\\ion\\Desktop\\sample.db");
                statement = connection.createStatement();
                statement.setQueryTimeout(30);

                statement.executeUpdate("CREATE TABLE IF NOT EXISTS person (id STRING PRIMARY KEY NOT NULL,"
                        + "name STRING, email STRING UNIQUE, password STRING)");

                statement.executeUpdate("CREATE TABLE IF NOT EXISTS message (id STRING PRIMARY KEY NOT NULL,"
                        + "text STRING, subject STRING, dateMessage Date, parrentMessageId String , personId String, "
                        + "categoryId String,"
                        + " FOREIGN KEY(personId) REFERENCES person(id),FOREIGN KEY(categoryId) REFERENCES category(id))");

                statement.executeUpdate(
                        "CREATE TABLE IF NOT EXISTS category (id STRING PRIMARY KEY NOT NULL," + "name STRING)");



        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

但是如果我在这样的 Servlet 中使用

String id = personService.getIdByEmail(email);

        message.setPersonId(id);
        messageService.persist(message);

我调用了两次不同的服务，这些服务调用了不同的存储库(personRep和messageRep都扩展了这个DbConnection类)它给了我“数据库已锁定”

如何检查连接是否已存在？请帮助我..谢谢!!

Answer 1

您正在使用两个设备同时调用两个服务。因此，服务器将创建两个线程并服务这两个请求。这两个头将同时打开两个连接。使用此连接，线程将执行具有 CREATE table 命令的 SQL 语句。这是DDL表达式。因此，一个线程获得数据库锁，而其他线程将成为瓶颈并给出“数据库被锁”等异常。

您可以使用同步，以便只允许一个线程执行代码。其他的要等到完成。

更多详细信息https://www.sqlite.org/cvstrac/wiki?p=DatabaseIsLocked