C# 使用list方法插入datatable中的資料到資料庫

前提：datatable裡有值，資料庫中有相應的表

一、list，string方法

            List<string> lstSql = new List<string>();

            for (int i = 0; i < dt.Rows.Count; i++)

                {

                    string ticketNo = dt.Rows[i]["票号"].ToString();

                    string actualcollect = dt.Rows[i]["實收款"].ToString().Replace("-", "");

                    string issueDate = Convert.ToDateTime(dt.Rows[i]["出票日期"].ToString()).ToString("yyyy-MM-dd").Replace("-", "");

                    string refundCharge = dt.Rows[i]["退票手續費（航空公司）"].ToString();

                    string approvalStatus = dt.Rows[i]["稽核狀态"].ToString();

                    sql = "insert into CMB_Refund_TktNo_Ref(OnlineRecordTicketNo,Actualcollect,IssueDate,ApprovalStatus,RefundCharge)"

                        + " values('{0}','{1}','{2}','{3}','{4}') ";

                    sql = string.Format(sql, ticketNo, actualcollect, issueDate, approvalStatus, refundCharge);

                    lstSql.Add(sql);

                }

                Hippo.ExecuteSqlTran(cmd);

               lstSql.Clear();

執行方法

       public static int ExecuteSqlTran(List<String> SQLStringList)

        {

            using (SqlConnection conn = new SqlConnection(connectionString))

            {

                conn.Open();

                SqlCommand cmd = new SqlCommand { Connection = conn };

                SqlTransaction tx = conn.BeginTransaction();

                cmd.Transaction = tx;

                try

                {

                    int count = 0;

                    for (int n = 0; n < SQLStringList.Count; n++)

                    {

                        string strsql = SQLStringList[n];

                        if (strsql.Trim().Length > 1)

                        {

                            cmd.CommandText = strsql;

                            count += cmd.ExecuteNonQuery();

                        }

                    }

                    tx.Commit();

                    return count;

                }

                catch

                {

                    tx.Rollback();

                    return 0;

                }

            }

        }

二、

             List<CommandInfo> cmd = new List<CommandInfo>();

             for (int i = 0; i < dt.Rows.Count; i++)

                {

                    StringBuilder strSqlConfig = new StringBuilder();

                    strSqlConfig.Append("insert into CMB_Refund_TktNo_Ref(OnlineRecordTicketNo,Actualcollect,IssueDate,ApprovalStatus,RefundCharge)"

                        + " values(@Tno,@Actcol,@Isdate,@Status,@Charge) ");

                    try

                    {

                        SqlParameter[] paraConfig =

                        {

                            new SqlParameter("@Tno", SqlDbType.NVarChar, 10),

                            new SqlParameter("@Actcol", SqlDbType.Float),

                            new SqlParameter("@Isdate", SqlDbType.NVarChar, 8),

                            new SqlParameter("@Status", SqlDbType.NVarChar, 8),

                            new SqlParameter("@Charge", SqlDbType.Float)

                        };

                        paraConfig[0].Value = dt.Rows[i]["票号"].ToString();

                        paraConfig[1].Value = dt.Rows[i]["實收款"].ToString().Replace("-", "");

                        paraConfig[2].Value =

                            Convert.ToDateTime(dt.Rows[i]["出票日期"].ToString()).ToString("yyyy-MM-dd").Replace("-", "");

                        paraConfig[3].Value = dt.Rows[i]["稽核狀态"].ToString();

                        paraConfig[4].Value = dt.Rows[i]["退票手續費（航空公司）"].ToString();

                        cmd.Add(new CommandInfo(strSqlConfig.ToString(), paraConfig));

                    }

                    catch (Exception ex)

                    {

                        MessageBox.Show("寫入資料庫時發生錯誤:{0}", ex.Message);

                        return;

                    }

                }

                Hippo.ExecuteSqlTran(cmd);

                cmd.Clear();

執行方法

       public static int ExecuteSqlTran(List<CommandInfo> cmdList)

        {

            using (SqlConnection conn = new SqlConnection(connectionString))

            {

                conn.Open();

                using (SqlTransaction trans = conn.BeginTransaction())

                {

                    SqlCommand cmd = new SqlCommand();

                    try

                    {

                        int count = 0;

                        //循環

                        foreach (CommandInfo myDE in cmdList)

                        {

                            string cmdText = myDE.CommandText;

                            SqlParameter[] cmdParms = (SqlParameter[])myDE.Parameters;

                            PrepareCommand(cmd, conn, trans, cmdText, cmdParms);

                            if (myDE.EffentNextType == EffentNextType.WhenHaveContine || myDE.EffentNextType == EffentNextType.WhenNoHaveContine)

                            {

                                if (myDE.CommandText.ToLower().IndexOf("count(") == -1)

                                {

                                    trans.Rollback();

                                    return 0;

                                }

                                object obj = cmd.ExecuteScalar();

                                bool isHave = false;

                                if (obj == null && obj == DBNull.Value)

                                {

                                    isHave = false;

                                }

                                isHave = Convert.ToInt32(obj) > 0;

                                if (myDE.EffentNextType == EffentNextType.WhenHaveContine && !isHave)

                                {

                                    trans.Rollback();

                                    return 0;

                                }

                                if (myDE.EffentNextType == EffentNextType.WhenNoHaveContine && isHave)

                                {

                                    trans.Rollback();

                                    return 0;

                                }

                                continue;

                            }

                            int val = cmd.ExecuteNonQuery();

                            count += val;

                            if (myDE.EffentNextType == EffentNextType.ExcuteEffectRows && val == 0)

                            {

                                trans.Rollback();

                                return 0;

                            }

                            cmd.Parameters.Clear();

                        }

                        trans.Commit();

                        return count;

                    }

                    catch

                    {

                        trans.Rollback();

                        throw;

                    }

                }

            }

        }

————————————————

版權聲明：本文為CSDN部落客「百裡禦」的原創文章，遵循 CC 4.0 BY-SA 版權協定，轉載請附上原文出處連結及本聲明。

原文連結：https://blog.csdn.net/u012698249/article/details/77494158