詳解Silverlight與MySQL數據庫互操作

作者：Kinglee 2009-09-07 15:25:24

開發后端

這里將談到Silverlight與MySQL數據庫互操作，首先將從建立測試項目，創建測試用數據庫開始，然后是對數據庫的操作。

Silverlight與MySQL數據庫互操作，也是因為MySQL在平時開發中應用得很多，適合大多數開發環境與要求。本文用到的MySQL環境是MySQL Connector Net 6.1.1，需要大家提前安裝。

準備工作

1）建立起測試項目

細節詳情請見強大的DataGrid組件[2]_數據交互之ADO.NET Entity Framework——Silverlight學習筆記[10]。

2）創建測試用數據庫

如下圖所示，創建一個名為employees的MySQL數據庫，建立數據表名稱為Employee。

創建測試用數據庫

3）安裝MySQL Connector Net 6.1.1 ★

為了能讓.NET操作MySQL數據庫，請務必安裝。

建立數據模型

EmployeeModel.cs文件（放置在服務端項目文件夾下）

using System;  
using System.Collections.Generic;  
using System.Linq;  
namespace dataformnmysqldb  
{  
    public class EmployeeModel  
    {  
        public int EmployeeID { get; set; }  
        public string EmployeeName { get; set; }  
        public int EmployeeAge { get; set; }  
    }  
}

建立服務端Web Service★

右擊服務端項目文件夾，選擇Add->New Item....，按下圖所示建立一個名為EmployeesInfoWebService.asmx的Web Service，作為Silverlight與MySQL數據庫互操作的橋梁。

建立服務端Web Service

在Silverlight客戶端應用程序文件夾下，右擊References文件夾，添加名為MySql.Data的命名空間。之后，雙擊EmployeesInfoWebService.asmx打開該文件，將里面的內容修改如下：

using System;  
using System.Collections.Generic;  
using System.Linq;  
using System.Web;  
using System.Web.Services;  
using System.Data;  
using MySql.Data.MySqlClient;//引入該命名空間是為了操作MySQL數據庫  
namespace dataformnmysqldb  
{  
    ///       /// Summary description for EmployeesInfoWebService  
    /// 
  
   [WebService(Namespace = "http://tempuri.org/")]  
    [WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]  
    [System.ComponentModel.ToolboxItem(false)]  
    // To allow this Web Service to be called from script, using ASP.NET AJAX, uncomment the following line.   
    // [System.Web.Script.Services.ScriptService]  
    public class EmployeesInfoWebService : System.Web.Services.WebService  
    {  
        [WebMethod]//獲取雇員信息  
        public List GetEmployeesInfo()  
        {  
            List returnedValue = new List();  
            MySqlCommand Cmd = new MySqlCommand();  
            SQLExcute("SELECT * FROM Employee", Cmd);  
            MySqlDataAdapter EmployeeAdapter = new MySqlDataAdapter();  
            EmployeeAdapter.SelectCommand = Cmd;  
            DataSet EmployeeDataSet = new DataSet();  
            EmployeeAdapter.Fill(EmployeeDataSet);  
            foreach (DataRow dr in EmployeeDataSet.Tables[0].Rows)  
            {  
                EmployeeModel tmp = new EmployeeModel();  
                tmp.EmployeeID = Convert.ToInt32(dr[0]);  
                tmp.EmployeeName = Convert.ToString(dr[1]);  
                tmp.EmployeeAge = Convert.ToInt32(dr[2]);  
                returnedValue.Add(tmp);  
            }  
           return returnedValue;  
        }  
        [WebMethod] //添加雇員信息  
        public void Insert(List employee)  
        {  
            employee.ForEach(x =>  
            {  
                string CmdText = "INSERT INTO Employee(EmployeeName,EmployeeAge) VALUES('" + x.EmployeeName + "'," + x.EmployeeAge.ToString() + ")";  
                SQLExcute(CmdText);  
            });  
        }  
        [WebMethod] //更新雇員信息  
        public void Update(List employee)  
        {  
            employee.ForEach(x =>  
            {  
                string CmdText = "UPDATE Employee SET EmployeeName='" + x.EmployeeName + "',EmployeeAge=" + x.EmployeeAge.ToString();  
                CmdText += " WHERE EmployeeID=" + x.EmployeeID.ToString();  
                SQLExcute(CmdText);  
            });  
        }  
        [WebMethod] //刪除雇員信息  
        public void Delete(List employee)  
        {  
            employee.ForEach(x =>  
            {  
                string CmdText = "DELETE FROM Employee WHERE EmployeeID=" + x.EmployeeID.ToString();  
                SQLExcute(CmdText);  
            });  
        }  
        //執行SQL命令文本，重載1  
        private void SQLExcute(string SQLCmd)  
        {  
            string ConnectionString = "server=localhost;user id=root;password=yourpassword;database=employees";  
            MySqlConnection Conn = new MySqlConnection(ConnectionString);  
            Conn.Open();  
            MySqlCommand Cmd = new MySqlCommand();  
            Cmd.Connection = Conn;  
            Cmd.CommandTimeout = 15;  
            Cmd.CommandType = System.Data.CommandType.Text;  
            Cmd.CommandText = SQLCmd;  
            Cmd.ExecuteNonQuery();  
            Conn.Close();  
        }  
        //執行SQL命令文本，重載2  
        private void SQLExcute(string SQLCmd, MySqlCommand Cmd)  
        {  
            string ConnectionString = "server=localhost;user id=root;password= yourpassword;database=employees";  
            MySqlConnection Conn = new MySqlConnection(ConnectionString);  
            Conn.Open();  
            Cmd.Connection = Conn;  
            Cmd.CommandTimeout = 15;  
            Cmd.CommandType = System.Data.CommandType.Text;  
            Cmd.CommandText = SQLCmd;  
            Cmd.ExecuteNonQuery();  
       }  
    }  
}