设为首页 收藏本站
查看: 1197|回复: 0

[经验分享] [原创]Silverlight与PostgreSQL数据库的互操作(CURD完全解析)

[复制链接]

尚未签到

发表于 2016-11-21 09:17:58 | 显示全部楼层 |阅读模式
今天将为大家介绍如何让Silverlight使用PostgreSQL作为后台数据库以及CURD操作。

准备工作
1)建立起测试项目
细节详情请见强大的DataGrid组件[2]_数据交互之ADO.NET Entity Framework——Silverlight学习笔记[10]。

2)创建测试用数据库
使用pgAdmin III,按下图所示,创建一个名为employeesPostgreSQL数据库,建立数据表名称为Employee。(注意:处理数据库对象时,PostgreSQLPL/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;
然后按“执行查询”按钮[绿色实心三角按钮]
DSC0000.png

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.asmxWeb Service,作为SilverlightMySQL数据库互操作的桥梁。

DSC0001.png

Silverlight
客户端应用程序文件夹下,右击References文件夹,添加名为NpgSql的命名空间(如下图)。

DSC0002.png


之后,双击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按钮进行查找)。

DSC0003.png

创建Silverlight客户端应用程序

详情参见我的[原创]SilverlightAccess数据库的互操作(CURD完全解析)

最终效果图
DSC0004.png



作者:Kinglee
文章出处:Kinglee&#8217;s Blog (http://www.cnblogs.com/Kinglee/)
版权声明:本文的版权归作者与博客园共有。转载时须注明本文的详细链接,否则作者将保留追究其法律责任。

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-303238-1-1.html 上篇帖子: PostgreSQL的时间/日期函数使用 下篇帖子: PostgreSQL 性能优化
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表