复制数据集/数据表到数据库文件

本文关键字：数据库 文件 数据表 数据集 复制 | 更新日期: 2023-09-27 18:15:55

我已经填充了一个数据集，该表是从另一个数据库文件创建的。表不是在数据库文件，我希望能够复制表到。

现在我想保存所有这些记录(DataTable)到一个新创建的SQLite数据库文件…

我该怎么做呢?

如果可能的话，我真的希望避免循环。

最好的答案是我:)所以我将分享它。这是一个循环，但在2-3秒内写入100k个条目。

using (DbTransaction dbTrans = kaupykliuduomConn.BeginTransaction())
{
  downloadas.Visible = true; //my progressbar
  downloadas.Maximum = dataSet1.Tables["duomenys"].Rows.Count;
  using (DbCommand cmd = kaupykliuduomConn.CreateCommand())
  {
    cmd.CommandText = "INSERT INTO duomenys(Barkodas, Preke, kiekis) VALUES(?,?,?)";
    DbParameter Field1 = cmd.CreateParameter();
    DbParameter Field2 = cmd.CreateParameter();
    DbParameter Field3 = cmd.CreateParameter();
    cmd.Parameters.Add(Field1);
    cmd.Parameters.Add(Field2);
    cmd.Parameters.Add(Field3);
    while (n != dataSet1.Tables["duomenys"].Rows.Count)
    {
      Field1.Value = dataSet1.Tables["duomenys"].Rows[n]["Barkodas"].ToString();
      Field2.Value = dataSet1.Tables["duomenys"].Rows[n]["Preke"].ToString();
      Field3.Value = dataSet1.Tables["duomenys"].Rows[n]["kiekis"].ToString();
      downloadas.Value = n;
      n++;
      cmd.ExecuteNonQuery();
    }
  }
  dbTrans.Commit();
}

在本例中为dataSet1。表["duomenys"]已经填满了我需要转移到另一个数据库的所有数据。我也使用循环填充数据集

复制数据集/数据表到数据库文件

  • 当您从源数据库加载DataTable时，将数据适配器的AcceptChangesDuringFill属性设置为false，使加载的记录保持在Added状态(假设源数据库是SQL Server)

    var sqlAdapter = new SqlDataAdapter("SELECT * FROM the_table", sqlConnection);
DataTable table = new DataTable();
sqlAdapter.AcceptChangesDuringFill = false;
sqlAdapter.Fill(table);

  • 在SQLite数据库中创建表，直接使用SQLiteCommand.ExecuteNonQuery

    • 执行CREATE TABLE语句。

  • 为SQLite数据库连接创建一个新的DataAdapter，并使用它来Update数据库:

    var sqliteAdapter = new SQLiteDataAdapter("SELECT * FROM the_table", sqliteConnection);
var cmdBuilder = new SQLiteCommandBuilder(sqliteAdapter);
sqliteAdapter.Update(table);

如果源表和目标表有相同的列名和兼容的类型，它应该工作得很好…

导入SQL数据到SQLite的时间会比较长。当您想要导入数百万的数据时，将会花费大量的时间。因此，最短和最简单的方法就是从DataTable的SQL数据库中获取数据，并将其所有行插入SQLite数据库。

public bool ImportDataToSQLiteDatabase(string Proc, string SQLiteDatabase, params object[] obj)
    {
        DataTable result = null;
        SqlConnection conn = null;
        SqlCommand cmd = null;
        try
        {
            result = new DataTable();
            using (conn = new SqlConnection(ConStr))
            {
                using (cmd = CreateCommand(Proc, CommandType.StoredProcedure, obj))
                {
                    cmd.Connection = conn;
                    conn.Open();
                    result.Load(cmd.ExecuteReader());
                }
            }
            using (SQLiteConnection con = new SQLiteConnection(string.Format("Data Source={0};Version=3;New=False;Compress=True;Max Pool Size=100;", SQLiteDatabase)))
            {
                con.Open();
                using (SQLiteTransaction transaction = con.BeginTransaction())
                {
                    foreach (DataRow row in result.Rows)
                    {
                        using (SQLiteCommand sqlitecommand = new SQLiteCommand("insert into table(fh,ch,mt,pn) values ('" + Convert.ToString(row[0]) + "','" + Convert.ToString(row[1]) + "','"
                                                                                                                              + Convert.ToString(row[2]) + "','" + Convert.ToString(row[3]) + "')", con))
                        {
                            sqlitecommand.ExecuteNonQuery();
                        }
                    }
                    transaction.Commit();
                    new General().WriteApplicationLog("Data successfully imported.");
                    return true;
                }
            }
        }
        catch (Exception ex)
        {
            result = null;
            return false;
        }
        finally
        {
            if (conn.State == ConnectionState.Open)
                conn.Close();
        }
    }

与上面给出的答案相比，这将花费很少的时间。

相关文章：