C# 操作SQLite 如何进行文件间的高效数据批量拷贝? 1C

有两个数据库文件,**a.db** 和 b.db,**b.db** 的某几个表比** a.db** 相应的表多了一两个字段,b.db里面多了两个表,其余都一样。
现要将** a.db** 的数据复制到 b.db 中,即相应字段的数据替换,有什么好的办法?
目前由于是循环遍历**a.db**表里面的数据,然后写入**b.db**里面,所以速度很慢,有什么高效快速的办法吗?下面贴代码:
从**a**表取数据:

                        DataSet DS = new DataSet();
            string sqlStr = "select TM,BZRQ,CBTM,CKH,KWH,WPH,PH,BZPH,DJP,PPH,MZ,JZ,XS,TMSD,RKZT,CKZT,WPLX,BZ from BZJL";
            string filename = FileUrl;
            string fullname;
            string myAppPath;
            fullname = System.Reflection.Assembly.GetExecutingAssembly().GetName().CodeBase;
            myAppPath = System.IO.Path.GetDirectoryName(fullname);
            myAppPath = myAppPath.Replace("file:\\", "");

            string connString = "Data Source=" + myAppPath + "\\DataBase\\" + filename;
            using (SQLiteConnection conn = new SQLiteConnection(connString))
            {
                conn.Open();
                SQLiteCommand cmd = conn.CreateCommand();
                cmd.CommandText = sqlStr;
                cmd.CommandType = CommandType.Text;
                SQLiteDataAdapter da = new SQLiteDataAdapter(cmd);
                DataSet ds = new DataSet();
                da.Fill(ds);
                DS = ds;
                conn.Close();
            }

然后写数据到**b.db**

                            using (SQLiteConnection conn = new SQLiteConnection(SQLLiteHelper.connString))
            {

                conn.Open();
                SQLiteTransaction sqltran = conn.BeginTransaction();
                List<string> sqlList = new List<string>();
                int fff = 0;

                DbTransaction trans = conn.BeginTransaction();
                try
                {
                    if (DS.Tables[0].Rows.Count >= 1)
                    {
                        foreach (DataRow dr in DS.Tables[0].Rows)
                        {
                            fff++;
                            List<System.Data.SQLite.SQLiteParameter> listPar = new List<System.Data.SQLite.SQLiteParameter>();
                            string TM = dr[0].ToString().Trim();
                            DateTime BZRQ = Convert.ToDateTime(dr[1].ToString());
                            string CBTM = dr[2].ToString().Trim();
                            string CKH = dr[3].ToString().Trim();
                            string KWH = dr[4].ToString().Trim();
                            string WPH = dr[5].ToString().Trim();
                            string PH = dr[6].ToString().Trim();
                            string BZPH = dr[7].ToString().Trim();
                            string DJP = dr[8].ToString().Trim();
                            string PPH = dr[9].ToString().Trim();
                            decimal MZ = decimal.Parse(dr[10].ToString());
                            decimal JZ = decimal.Parse(dr[11].ToString());
                            int XS = int.Parse(dr[12].ToString());
                            string TMSD = dr[13].ToString().Trim();
                            string RKZT = dr[14].ToString().Trim();
                            string CKZT = dr[15].ToString().Trim();
                            string WPLX = dr[16].ToString().Trim();
                            string BZ = dr[17].ToString().Trim();
                            string sql = "insert into BZJL (TM,BZRQ,CBTM,CKH,KWH,WPH,PH,BZPH,DJP,PPH,MZ,JZ,XS,TMSD,RKZT,CKZT,WPLX,BZ)" +
                                      " VALUES (@TM,@BZRQ,@CBTM,@CKH,@KWH,@WPH,@PH,@BZPH,@DJP,@PPH,@MZ,@JZ,@XS,@TMSD,@RKZT,@CKZT,@WPLX,@BZ)";
                            sqlList.Add(sql);
                            System.Data.SQLite.SQLiteParameter[] par = { 
                                                                           new System.Data.SQLite.SQLiteParameter("@TM", TM),
                                                                           new System.Data.SQLite.SQLiteParameter("@BZRQ", BZRQ),
                                                                           new System.Data.SQLite.SQLiteParameter("@CBTM", CBTM),
                                                                           new System.Data.SQLite.SQLiteParameter("@CKH", CKH),
                                                                           new System.Data.SQLite.SQLiteParameter("@KWH", KWH),
                                                                           new System.Data.SQLite.SQLiteParameter("@WPH", WPH),
                                                                           new System.Data.SQLite.SQLiteParameter("@PH", PH),
                                                                           new System.Data.SQLite.SQLiteParameter("@BZPH", BZPH),
                                                                           new System.Data.SQLite.SQLiteParameter("@DJP", DJP),
                                                                           new System.Data.SQLite.SQLiteParameter("@PPH", PPH),
                                                                           new System.Data.SQLite.SQLiteParameter("@MZ", MZ),
                                                                           new System.Data.SQLite.SQLiteParameter("@JZ", JZ),
                                                                           new System.Data.SQLite.SQLiteParameter("@XS", XS),
                                                                           new System.Data.SQLite.SQLiteParameter("@TMSD", TMSD),
                                                                           new System.Data.SQLite.SQLiteParameter("@RKZT", RKZT),
                                                                           new System.Data.SQLite.SQLiteParameter("@CKZT", CKZT),
                                                                           new System.Data.SQLite.SQLiteParameter("@WPLX", WPLX),
                                                                           new System.Data.SQLite.SQLiteParameter("@BZ", BZ)
                                                                       };
                            help.ExecuteSqlListPar(conn, sql, par, sqltran);
                        }
                        sqltran.Commit();
                        conn.Close();
                    }
                }
                catch
                {
                    sqltran.Rollback();
                    //throw;
                    MessageBox.Show("写入超时","温馨提示");
                }
            }

1个回答

每次读取一批量的数据(比如1000条记录)读入数组,然后批量的写入。

W_learner
W_learner 那和这个也差不多呀,35000条数据用了将近5分钟
接近 3 年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问