从 DataTable 批量插入到 SQLCE DataSource

Question

这是一个使用 SQL CE 作为数据源的 C# WPF 应用程序：

我有一个 DataTable（显示为 DataGrid）和一个 SQL CE 数据源。 我使用 DataAdapter、DataSet 和 DataTable 从 SQL CE 填充 DataTable。然后将我的 DataGrid 绑定到 DataTable。

我可以将行（>10,000）行添加到我的数据表中，并且可以在将所有更改一起传播到我的 Sql CE 数据源之前编辑数据。

我当前的方法是 DROP TABLE、CREATE TABLE 并通过强力将行重新插入到 SQLCE。 SQL CE 没有批量插入，并且我不想使用第三个库或 dll。性能很慢...

我正在寻找一种更快的“批量插入”方法，而不需要逐一删除、创建和插入行。

我读了一些有关 SqlCeResultSet 的内容，但找不到任何文档，想知道它与我想做的事情有什么关系。

[编辑]
按照答案并检查这​​一点：
http://ruudvanderlinden.com/2010/ 10/13/bulk-insert-into-sql-ce-in-c/

我尝试使用该功能，但似乎不起作用。 下面是我的代码。 Footable 是我的数据库表，我有两列 - “id”和“FooName”。

Hashtable idHash = new Hashtable();
Hashtable fooNameHash = new Hashtable();
foreach(DataRow row in dt.Rows)
{
    idHash.Add("id",row["id"]);
    fooNameHash.Add("FooName",row["FooName"]);
}

List<Hashtable> colHashList = new List<Hashtable>();
colHashList.Add(idHash);
colHashList.Add(fooNameHash);

BulkInsertDatabase(colHashList, "FooTable");

它不起作用，但我在上面的代码中没有看到任何问题，所以希望有人能指出它..

[编辑 - 2nd][ANSWER]
最后我让代码可以工作（尽管性能值得怀疑）：

List<Hashtable> colHashList = new List<Hashtable>();

Hashtable[] idHash = new Hashtable[dt.Rows.Count];
Hashtable[] fooNameHash = new Hashtable[dt.Rows.Count];

int i=0;
foreach(DataRow row in dt.Rows)
{
    idHash[i] = new Hashtable();
    idHash[i].Add("id", row["id"]);
    colHashList.Add(idHash[i]);

    fooNameHash[i] = new Hashtable();
    fooNameHash[i].Add("FooName", row["FooName"]);
    colHashList.Add(fooNameHash[i]);

    i++;
}

BulkInsertDatabase(colHashList, "FooTable");

Answer 1

您应该使用 SqlCeResultSet 类< /a>

它允许在 SQL CE 数据库中批量导入 我在 10 秒内导入了 100000 行
查看示例

Answer 2

您可以在此处使用我的批量插入库中的 C# 源代码：http://sqlcebulkcopy.codeplex.com

Answer 3

它的工作，试试这个。

 public bool CopyDataTableToTable(DataTable dataTable, string tableName, bool deleteTable)
        {
            Boolean returnValue = true;
            if (sqlCeConnection.State == ConnectionState.Closed)
                sqlCeConnection.Open();

            SqlCeTransaction transaction = sqlCeConnection.BeginTransaction();
            SqlCeCommand cmd = sqlCeConnection.CreateCommand();
            SqlCeResultSet rs = null;
            try
            {
                if (deleteTable)
                {
                    cmd.Transaction = transaction;
                    cmd.CommandText = "DELETE " + tableName;
                    cmd.ExecuteNonQuery();
                }

                cmd.CommandType = System.Data.CommandType.TableDirect;
                cmd.CommandText = tableName;
                rs = cmd.ExecuteResultSet(ResultSetOptions.Updatable);

                for (int i = 0; i < dataTable.Rows.Count; i++)
                {
                    SqlCeUpdatableRecord rec = rs.CreateRecord();
                    DataRow row = dataTable.Rows[i];
                    for (int k = 0; k < dataTable.Columns.Count - 1; k++)
                    {
                        rec.SetValue(k + 1, row[k]);
                    }
                    rs.Insert(rec);
                }
                transaction.Commit();
            }

            catch (Exception ex)
            {
                returnValue = false;
                transaction.Rollback();
            }
            finally
            {
                rs.Close();
                if (sqlCeConnection.State == ConnectionState.Open)
                    sqlCeConnection.Close();

            }
            return returnValue;
        }