ASP.NET MVC與Sql Server交互,把字典數據插入數據庫

 

在"ASP.NET MVC與Sql Server交互, 插入數據"中，在Controller中拼接sql語句。比如：

 

_db.InsertData("insert into Product(Name,quantity,Price) values('"+productVm.Name+"','"+productVm.Quantity+"','"+productVm.Price+"')");

 

在某些場景中需要把數據放在字典集合中，再插入到數據庫。類似如下：

 

_db.InsertDataByDic("表名", 字典集合);

 

這樣有更好的可讀性。字典集合的鍵是表的字段們。

 

於是，可以把相對復雜的sql語句拼接放在了幫助類中。在幫助類中增加一個InsertDataByDic方法，該方法遍歷字典集合拼接sql語句。

 

     public class SqlDB
    {
        protected SqlConnection conn;
        //打開連接
        public bool OpenConnection()
        {
            conn = new SqlConnection(ConfigurationManager.ConnectionStrings["DefaultConnection"].ConnectionString);
            try
            {
                bool result = true;
                if (conn.State.ToString() != "Open")
                {
                    conn.Open();
                }
                return result;
            }
            catch (SqlException ex)
            {
                return false;
            }
        }
        //關閉連接
        public bool CloseConnection()
        {
            try
            {
                conn.Close();
                return true;
            }
            catch (Exception ex)
            {
                return false;
            }
        }
        //插入數據
        public int InsertData(string sql)
        {
            int lastId = 0;
            //string query = sql + ";SELECT @@Identity;";
            try
            {
                if(conn.State.ToString()=="Open")
                {
                    SqlCommand cmd = new SqlCommand(sql, conn);
                    //cmd.ExecuteNonQuery();
                    lastId = ToInt(cmd.ExecuteScalar());//返回第一行的第一列
                }
                return ToInt(lastId);
            }
            catch (Exception ex)
            {
                return 0;
            }
        }
        //轉換成整型
        private int ToInt(object o)
        {
            try
            {
                return int.Parse(o.ToString());
            }
            catch (Exception ex)
            {
                return 0;
            }
        }
        //插入字典數據
        public int InsertDataByDic(string tableName, Dictionary<string,string> dics)
        {
            int lastId = 0;
            string keyStr = string.Empty;//拼接鍵
            string valStr = string.Empty;//拼接變量
            int index = 0;//索引
            try
            {
                foreach (KeyValuePair<string, string> item in dics)
                {
                    index++;
                    //第一次拼接前面逗號
                    keyStr += (index != 1 ? "," : "") + "[" + item.Key + "]";
                    valStr += (index != 1 ? "," : "") + "@" + item.Key;
                }
                //拼接sql語句
                string query = "insert into " + tableName + "(" + keyStr + ") values (" + valStr + ");SELECT @@Identity;";
                if (conn.State.ToString() == "Open")
                {
                    SqlCommand cmd = new SqlCommand(query, conn);
                    foreach (KeyValuePair<string, string> item in dics)
                    {
                        cmd.Parameters.AddWithValue("@" + item.Key, item.Value);
                    }
                    lastId = ToInt(cmd.ExecuteScalar());
                }
                return ToInt(lastId);
            }
            catch (Exception ex)
            {
                return 0;
            }
        }
    }

 

在TestController中增加2個名稱為AddProductByDic的Action方法，把從前端獲取到的視圖模型中的數據賦值給字典集合。

 

  public class TestController : Controller
    {
        private SqlDB _db = new SqlDB();
        //
        // GET: /Test/
        public ActionResult Index()
        {
            bool r = _db.OpenConnection();
            if (r)
            {
                return Content("連接成功");
            }
            else
            {
                return Content("連接失敗");
            }
        }
        //通過sql語句插入數據
        public ActionResult AddProduct()
        {
            return View();
        }
        [HttpPost]
        [ValidateAntiForgeryToken]
        public ActionResult AddProduct(ProductVm productVm)
        {
            if(ModelState.IsValid)
            {
                _db.OpenConnection();
                int result = _db.InsertData("insert into Product(Name,quantity,Price) values('"+productVm.Name+"','"+productVm.Quantity+"','"+productVm.Price+"')");
                if(result > 0)
                {
                    ModelState.AddModelError("success", "創建成功");
                }
                else
                {
                    ModelState.AddModelError("error", "創建失敗");
                }
                _db.CloseConnection();
                return RedirectToAction("Index");
            }
            else
            {
                return View(productVm);
            }
        }
        //通過字典集合插入數據
        public ActionResult AddProductByDic()
        {
            return View();
        }
        [HttpPost]
        [ValidateAntiForgeryToken]
        public ActionResult AddProductByDic(ProductVm productVm)
        {
            int i = 0;
            if (ModelState.IsValid)
            {
                _db.OpenConnection();
                Dictionary<string, string> data = new Dictionary<string, string>();
                data["Name"] = productVm.Name;
                data["quantity"] = productVm.Quantity;
                data["Price"] = productVm.Price;
                i = _db.InsertDataByDic("Product", data);
                _db.CloseConnection();
                if(i>0)
                {
                    return RedirectToAction("Index");
                }
                else
                {
                    return View(productVm);
                }
            }
            else
            {
                return View(productVm);
            }
        }
    }

 

AddProductByDic.cshtml是一個強類型視圖。

 

@model Portal.Models.ProductVm
@{
    ViewBag.Title = "AddProductByDic";
    Layout = "~/Views/Shared/_Layout.cshtml";
}
<h2>AddProductByDic</h2>
@using (Html.BeginForm("AddProductByDic", "Test", new { @id = "addForm" }, FormMethod.Post))
{
    @Html.AntiForgeryToken()
    
    <div class="form-horizontal">
        <h4>ProductVm</h4>
        <hr />
        @Html.ValidationSummary(true)
        <div class="form-group">
            @Html.LabelFor(model => model.Name, new { @class = "control-label col-md-2" })
            <div class="col-md-10">
                @Html.EditorFor(model => model.Name)
                @Html.ValidationMessageFor(model => model.Name)
            </div>
        </div>
        <div class="form-group">
            @Html.LabelFor(model => model.Quantity, new { @class = "control-label col-md-2" })
            <div class="col-md-10">
                @Html.EditorFor(model => model.Quantity)
                @Html.ValidationMessageFor(model => model.Quantity)
            </div>
        </div>
        <div class="form-group">
            @Html.LabelFor(model => model.Price, new { @class = "control-label col-md-2" })
            <div class="col-md-10">
                @Html.EditorFor(model => model.Price)
                @Html.ValidationMessageFor(model => model.Price)
            </div>
        </div>
        <div class="form-group">
            <div class="col-md-offset-2 col-md-10">
                <input type="submit" value="創建" class="btn btn-default" />
            </div>
        </div>
    </div>
}
<div>
    @Html.ActionLink("Back to List", "Index")
</div>