0

我需要帮助:我的代码中有两种方法——一种用于插入数据,一种用于更新数据——我首先调用“插入方法”,第二次调用“更新方法”,但在第二次情况下,我收到“锁定数据库错误”。

这里的方法:

  private bool mappingFileInDB(string numRep, string siglaNot, string annoPrat, string ErrorImporting, string fishedOut)
  {
        using (SQLiteConnection sqlite_conn = new SQLiteConnection("Data Source=" + pathProjectDir + @"\db\db.dat;"))
        {
            sqlite_conn.Open();
            using (SQLiteCommand insertSQL = new SQLiteCommand("INSERT INTO working_table (numero_repertorio, sigla_notaio, codice_pratica, anno_cartella, is_file_imported, if_error_importing, is_file_glyphed, is_cc_in_outFolder, is_td_in_toSignFolder, is_td_signed, is_td_in_signedFolder, is_td_in_notaroFolder, is_fishedOut ) VALUES (@1,@2,@3,@4,@5,@6,@7,@8,@9,@10,@11,@12,@13)", sqlite_conn))
            {
                insertSQL.Parameters.Add(new SQLiteParameter("@1", numRep));
                insertSQL.Parameters.Add(new SQLiteParameter("@2", siglaNot));
                insertSQL.Parameters.Add(new SQLiteParameter("@3", ""));
                insertSQL.Parameters.Add(new SQLiteParameter("@4", annoPrat));
                insertSQL.Parameters.Add(new SQLiteParameter("@5", "0"));
                insertSQL.Parameters.Add(new SQLiteParameter("@6", ErrorImporting));
                insertSQL.Parameters.Add(new SQLiteParameter("@7", "0"));
                insertSQL.Parameters.Add(new SQLiteParameter("@8", "0"));
                insertSQL.Parameters.Add(new SQLiteParameter("@9", "0"));
                insertSQL.Parameters.Add(new SQLiteParameter("@10", "0"));
                insertSQL.Parameters.Add(new SQLiteParameter("@11", "0"));
                insertSQL.Parameters.Add(new SQLiteParameter("@12", "0"));
                insertSQL.Parameters.Add(new SQLiteParameter("@13", fishedOut));
                try
                {
                    insertSQL.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    return false;
                }
                finally
                {
                    sqlite_conn.Close();
                    sqlite_conn.Dispose();
                }
            }

        }
        GC.Collect();
        return true;
 }

 public bool updateFileInDB(string nameColumn, string newVal, string numRep, string siglaNot)
    {
        using (SQLiteConnection sqlite_conn = new SQLiteConnection("Data Source=" + pathProjectDir + @"\db\db.dat;"))
        {
            sqlite_conn.Open();
            using (SQLiteCommand updateSQL = new SQLiteCommand("UPDATE working_table SET " + nameColumn + " = @val WHERE numero_repertorio = @nR AND sigla_notaio = @sN", sqlite_conn))
            {
                updateSQL.Parameters.Add(new SQLiteParameter("@val", newVal));
                updateSQL.Parameters.Add(new SQLiteParameter("@nR", numRep));
                updateSQL.Parameters.Add(new SQLiteParameter("@sN", siglaNot));

                try
                {
                    updateSQL.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    return false;
                }
                finally
                {
                    sqlite_conn.Close();
                    sqlite_conn.Dispose();
                }
            }
        }
        GC.Collect();
        return true;
    }

这里的错误:

错误截图

PS:如果我多次调用 insert 方法,它可以正常工作;如果我只调用更新方法 - 之前没有插入一些东西 - 它可以工作;仅当我首先调用 insert 方法和第二次调用 update 方法时,它才起作用。

我不明白问题出在哪里!

4

1 回答 1

0

现在它起作用了!我改变了这个:

insertSQL.ExecuteNonQuery();

有了这个:

insertSQL.ExecuteScalar();

并且工作正常!

谁能告诉我为什么?

于 2017-10-30T20:39:11.443 回答