码迷,mamicode.com
首页 > 数据库 > 详细

【SQLite】使用事务处理带参数的插入

时间:2015-09-10 13:04:47      阅读:211      评论:0      收藏:0      [点我收藏+]

标签:

using (SQLiteConnection conn = new SQLiteConnection(String.Format("Data Source={0};Pooling=true",fileName.ToString())))
            {
                using (SQLiteCommand cmd = new SQLiteCommand())
                {
                    conn.Open();
                    cmd.Connection = conn;
                    Stopwatch warch = new Stopwatch();
                    warch.Start();

                    SQLiteTransaction trans = conn.BeginTransaction();
                    cmd.Transaction = trans;
                    try
                    {
                        for (int i = 0; i < _dataTable.Rows.Count; i++)
                        {
                            cmd.CommandText =
                                "insert into HistoryData (PointId,PointType,TempValue,HumiValue,TTime) values (@PointId,@PointType,@TempValue,@HumiValue,@TTime)";
                            cmd.Parameters.Add(new SQLiteParameter("@PointId", DbType.Int32));
                            cmd.Parameters.Add(new SQLiteParameter("@PointType", DbType.String, 20));
                            cmd.Parameters.Add(new SQLiteParameter("@TempValue", DbType.Double));
                            cmd.Parameters.Add(new SQLiteParameter("@HumiValue", DbType.Double));
                            cmd.Parameters.Add(new SQLiteParameter("@TTime", DbType.DateTime));

                            cmd.Parameters[0].Value = _dataTable.Rows[i]["PointId"].ToString();
                            cmd.Parameters[1].Value = _dataTable.Rows[i]["PointType"].ToString();
                            cmd.Parameters[2].Value = _dataTable.Rows[i]["TempValue"].ToString();
                            cmd.Parameters[3].Value = _dataTable.Rows[i]["HumiValue"].ToString();
                            cmd.Parameters[4].Value = _dataTable.Rows[i]["TTime"];

                            cmd.ExecuteNonQuery();
                        }

                        trans.Commit();
                    }
                    catch (Exception)
                    {
                        trans.Rollback();
                        throw;
                    }

                    warch.Stop();
                    MessageBox.Show(string.Format("{0},{1}",_dataTable.Rows.Count,
                warch.Elapsed.ToString()));
                }
            }

使用事务处理插入sqlite数据库中的语句

【SQLite】使用事务处理带参数的插入

标签:

原文地址:http://www.cnblogs.com/mzy-google/p/4797289.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!