[分享]Silverlight访问数据库之MySQL数据库_MySQL, Oracle及数据库讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛_联动北方技术论坛  
网站首页 | 关于我们 | 服务中心 | 经验交流 | 公司荣誉 | 成功案例 | 合作伙伴 | 联系我们 |
联动北方-国内领先的云技术服务提供商
»  游客             当前位置:  论坛首页 »  自由讨论区 »  MySQL, Oracle及数据库讨论区 »
总帖数
1
每页帖数
101/1页1
返回列表
0
发起投票  发起投票 发新帖子
查看: 1964 | 回复: 0   主题: [分享]Silverlight访问数据库之MySQL数据库        下一篇 
koei666
注册用户
等级:新兵
经验:61
发帖:63
精华:0
注册:2012-1-9
状态:离线
发送短消息息给koei666 加好友    发送短消息息给koei666 发消息
发表于: IP:您无权察看 2014-11-19 11:27:40 | [全部帖] [楼主帖] 楼主

本文将为大家介绍如何让Silverlight使用MySQL作为后台数据库以及CURD操作。

准备工作

1)建立起测试项目

细节详情请见强大的DataGrid组件[2]_数据交互之ADO.NET Entity Framework

2)创建测试用数据库

如下图所示,创建一个名为employees的MySQL数据库,建立数据表名称为Employee。

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文件夹,添加名为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>
/// 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>();
            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<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;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();
      }
}


之后,在Silverlight客户端应用程序文件夹下,右击References文件夹,选择菜单选项Add Service Reference...。如下图所示,引入刚才我们创建的Web Service(别忘了按Discover按钮进行查找)。

创建Silverlight客户端应用程序

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

--转自 北京联动北方科技有限公司




赞(0)    操作        顶端 
总帖数
1
每页帖数
101/1页1
返回列表
发新帖子
请输入验证码: 点击刷新验证码
您需要登录后才可以回帖 登录 | 注册
技术讨论