Silverlight與PostgreSQL數據庫的互操作(CURD完全解析)

作者: Kinglee 來源: 博客園發布時間: 2010-08-13 20:09 閱讀: 1226 次推薦: 0 原文鏈接 [收藏]

　　今天將為大家介紹如何讓Silverlight使用PostgreSQL作為后臺數據庫以及CURD操作。

　　準備工作

　　1）建立起測試項目

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

　　2）創建測試用數據庫

　　使用pgAdmin III，按下圖所示，創建一個名為employees的PostgreSQL數據庫，建立數據表名稱為Employee。（注意：處理數據庫對象時，PostgreSQL的PL/pgSQL語言具有區分大小寫的內在屬性，數據表名和列名均需使用雙引號包住，引用自鏈接）【我用的PostgreSQL數據庫版本為8.3.7，點擊下載】

　　點擊pgAdmin III工具欄上的“執行任意的SQL查詢”[筆和紙的按鈕]，在彈出的窗口中輸入如下SQL語句：

CREATE TABLE "Employee"
(
"EmployeeID" integer NOT NULL DEFAULT nextval('employees_employeeid_seq'::regclass),
"EmployeeName" character varying(45) NOT NULL,
"EmployeeAge" integer NOT NULL,
CONSTRAINT employees_pkey PRIMARY KEY ("EmployeeID")
)
WITH (OIDS=FALSE);
ALTER TABLE "Employee" OWNER TO postgres;

然后按“執行查詢”按鈕[綠色實心三角按鈕]

　　3）下載Npgsql ★

　　為了能讓.NET操作PostgreSQL數據庫，請務必下載。【點擊：下載】

下載解壓后，將bin文件夾中的全部內容復制到服務端項目文件夾下的bin文件夾中（之后，將該文件夾包含進來），便于管理引用。

　　建立數據模型

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

using System;
using System.Collections.Generic;
using System.Linq;
namespace dataformpostgresqldb
{
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數據庫互操作的橋梁。

　　在Silverlight客戶端應用程序文件夾下，右擊References文件夾，添加名為NpgSql的命名空間（如下圖）。

　　之后，雙擊EmployeesInfoWebService.asmx打開該文件，將里面的內容修改如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.Services;
using System.Data;
using Npgsql;//引入該命名空間是為了操作PostgreSQL數據庫
namespace dataformpostgresqldb
{
/// <summary>
/// Summary description for EmployeesInfoWebService
/// </summary>
[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<EmployeeModel> GetEmployeesInfo()
{
List<EmployeeModel> returnedValue = new List<EmployeeModel>();
NpgsqlCommand Cmd = new NpgsqlCommand();
SQLExcute(@"SELECT * FROM ""Employee"" ORDER BY ""EmployeeID"" ASC", Cmd);
NpgsqlDataAdapter EmployeeAdapter = new NpgsqlDataAdapter();
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<EmployeeModel> employee)
{
employee.ForEach(x =>
{
string CmdText = @"INSERT INTO "
"Employee""(""EmployeeName"",""EmployeeAge"")
VALUES('" + x.EmployeeName + "'," + x.EmployeeAge.ToString() + ")";
SQLExcute(CmdText);
});
}
[WebMethod] //更新雇員信息
public void Update(List<EmployeeModel> 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<EmployeeModel> 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;uid=postgres;pwd=yourpwd;database=employees";
NpgsqlConnection Conn = new NpgsqlConnection(ConnectionString);
Conn.Open();
NpgsqlCommand Cmd = new NpgsqlCommand();
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, NpgsqlCommand Cmd)
{
string ConnectionString =
"server=localhost;uid=postgres;pwd=yourpwd;database=employees";
NpgsqlConnection Conn = new NpgsqlConnection(ConnectionString);
Conn.Open();
Cmd.Connection = Conn;
Cmd.CommandTimeout = 15;
Cmd.CommandType = System.Data.CommandType.Text;
Cmd.CommandText = SQLCmd;
Cmd.ExecuteNonQuery();
}
}
}

　　在Silverlight客戶端應用程序文件夾下，右擊References文件夾，選擇菜單選項Add Service Reference...。如下圖所示，引入剛才我們創建的Web Service（別忘了按Discover按鈕進行查找）。

　　創建Silverlight客戶端應用程序