C# SQLite数据库已锁定

isr3a4wc 于 2022-11-30 发布在 SQLite

关注(0)|答案(1)|浏览(230)

我有一个名为ImageData的类，其中包含一个标签列表。只有当图像具有1个以上的标签时，我才会收到数据库锁定错误，并且我无法找出为什么0标签和1标签总是可以的原因，无论是1个图像还是100个图像。只要1个图像具有2个标签，我就会收到错误
我确保使用using语句处理所有内容
方法如下

public static int addImages(List<ImageData> images)
    {
        int rows = 0;
        using (SQLiteConnection con = new SQLiteConnection(ConnectionString()))
        {
            con.Open();
            foreach (ImageData img in images)
            {
                using (SQLiteCommand cmd = new SQLiteCommand($"INSERT INTO images(Hash, Extension, Name) VALUES(@IHash,@IExtension, @IName)", con))
                {
                    cmd.Parameters.AddWithValue("@IHash", img.Hash);
                    cmd.Parameters.AddWithValue("@IExtension", img.Extension);
                    cmd.Parameters.AddWithValue("@IName", img.Name);
                    rows += cmd.ExecuteNonQuery();
                }
                foreach (Tag tag in img.Tags)
                {
                    using (SQLiteCommand cmd = new SQLiteCommand($"INSERT INTO ImagesTags(ImageHash, TagName) VALUES(@IHash,@IName)", con))
                    {
                        cmd.Parameters.AddWithValue("@IHash", img.Hash);
                        cmd.Parameters.AddWithValue("@IName", tag.Name);
                        cmd.ExecuteNonQuery();
                    }
                }
            }
            con.Close();
        }
        
        return rows;
    }

这是我的表创建

string[] createTable =
        {
            "CREATE TABLE images(Hash TEXT PRIMARY KEY, Extension TEXT, Name TEXT)",
            "CREATE TABLE tags(NAME TEXT PRIMARY KEY NOT NULL,DESCRIPTION TEXT,COLLECTIONNAME TEXT)",
            "CREATE TABLE ImagesTags(ImageHash TEXT,TagName TEXT,Primary KEY (ImageHash, TagName),FOREIGN KEY (ImageHash) REFERENCES images(Hash),FOREIGN KEY (TagName) REFERENCES tags(Name))"

        };

在foreach循环中插入数据的情况有很多，但这是唯一出现此错误的地方。

sqlite

来源：https://stackoverflow.com/questions/74585052/c-sharp-sqlite-database-is-locked

1条答案

按热度按时间

vdgimpew1#

在谷歌上搜索了很多之后，我了解到了使用sqlite的更干净的方法。
通过对每个连接、命令、事务和读取器使用using语句解决了这个问题。
一定是某个地方的某样东西被错误地处理了
这里的函数与前面的函数相同，但是我使用了更好的代码，我还添加了事务，以便只对数据库进行一次调用，并且在出现错误时允许回滚

public static int addImages(List<ImageData> images)
    {
        int rows = 0;
        using (var con = new SQLiteConnection(ConnectionString()))
        {
            con.Open();
            
            using (var tra = con.BeginTransaction())
            {
                try
                {
                    foreach (ImageData img in images)
                    {
                        SQLiteParameter p1 = new SQLiteParameter("@IHash", System.Data.DbType.String);
                        SQLiteParameter p2 = new SQLiteParameter("@IExtension", System.Data.DbType.String);
                        SQLiteParameter p3 = new SQLiteParameter("@IName", System.Data.DbType.String);
                        using (SQLiteCommand cmd = new SQLiteCommand($"INSERT INTO images(Hash, Extension, Name) VALUES(@IHash,@IExtension, @IName)", tra.Connection))
                        {

                            cmd.Parameters.Add(p1);
                            cmd.Parameters.Add(p2);
                            cmd.Parameters.Add(p3);

                            p1.Value = img.Hash;
                            p2.Value = img.Extension;
                            p3.Value = img.Name;
                            cmd.ExecuteNonQuery();
                        }

                        foreach (Tag tag in img.Tags)
                        {
                            using (SQLiteCommand cmd = new SQLiteCommand($"INSERT INTO ImagesTags(ImageHash, TagName) VALUES(@IHash,@IName)", tra.Connection))
                            {
                                cmd.Parameters.AddWithValue("@IHash", img.Hash);
                                cmd.Parameters.AddWithValue("@IName", tag.Name);
                                cmd.ExecuteNonQuery();
                            }
                        }

                    }
                    tra.Commit();
                }
                catch(Exception ex) 
                {
                    tra.Rollback();
                    throw;
                }
            }

        }
        return rows;
    }

赞(0）回复(0）举报 2022-11-30

我来回答

C# SQLite数据库已锁定

1条答案

相关问题

热门标签

最新问答