silverlight通过WCF连接数据库之增删改查

using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text;

namespace HouseShopping.Web.APPData.Login
{
    // 注意: 使用“重构”菜单上的“重命名”命令，可以同时更改代码和配置文件中的接口名“ILoginAndResister”。
    [ServiceContract]
    public interface ILoginAndResister
    {
        [OperationContract]
        void OpenSQL();
        [OperationContract]
        void CloseSQL();
        [OperationContract]
        string QuerySQL(string UserName, string pwd);
        [OperationContract]
        int AddUsers(string Username, string pwd);
        [OperationContract]
        int UpdateUsers(string Username, string pwd);
        [OperationContract]
        int DeleteUsers(string Username);
    }
}

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text;

namespace HouseShopping.Web.APPData.Login
{
    // 注意: 使用“重构”菜单上的“重命名”命令，可以同时更改代码、svc 和配置文件中的类名“LoginAndResister”。
    // 注意: 为了启动 WCF 测试客户端以测试此服务，请在解决方案资源管理器中选择 LoginAndResister.svc 或 LoginAndResister.svc.cs，然后开始调试。
    public class LoginAndResister : ILoginAndResister
    {
        SqlConnection strCon = new SqlConnection(@"server=.MySql;database=AnJuKe_DB;user id=sa;password=123;");
        //server=SQLServer服务器名称;database=数据库名称;uid=用户名;pwd=密码"
        public void OpenSQL()
        {
            strCon.Open();
        }

        public void CloseSQL()
        {
            strCon.Close();
        }
        public string QuerySQL(string UserName, string pwd)
        {
            try
            {
                OpenSQL();
                string strSql = string.Format("select * from T_Users where Name like '%{0}%' and Password like '%{1}%'", UserName, pwd);
                DataSet ds = new DataSet();
                SqlDataAdapter s = new SqlDataAdapter(strSql, strCon);
                s.Fill(ds);
                return ds.GetXml();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();
            }
        }
        public int AddUsers(string Username, string pwd)
        {

            try
            {
                OpenSQL();
                string strInsert = "insert into T_Users values('" + Username + "','" + pwd + "')";
                SqlCommand cmd = new SqlCommand(strInsert, strCon);
                return cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();
            }

        }
        public int UpdateUsers(string Username, string pwd)
        {

            try
            {
                OpenSQL();
                string strUpdate = "UPDATE T_Users SET Password = '" + pwd + "' WHERE Name = '" + Username + "'";
                SqlCommand cmd = new SqlCommand(strUpdate, strCon);
                return cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();
            }
        }
        public int DeleteUsers(string Username)
        {
            try
            {
                OpenSQL();
                string strDelete = "delete from T_Users where Name='" + Username + "'";
                SqlCommand cmd = new SqlCommand(strDelete, strCon);
                return cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();
            }
        }
    }
}

using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Documents;
using System.Windows.Ink;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Animation;
using System.Windows.Shapes;
using System.Xml;
using HouseShopping.MyLoginService;

namespace HouseShopping.MyClasses
{
    public class UsersManageClass
    {
      private  LoginAndResisterClient client;
      private TextBlock tb;
        private string Username;
        public void BeginRegister( string UserName,string pwd)
        {           
            client = new LoginAndResisterClient();
            client.AddUsersCompleted += client_AddUsersCompleted;
            client.AddUsersAsync(UserName, pwd);
        }
        void client_AddUsersCompleted(object sender, AddUsersCompletedEventArgs e)
        {
            if (Convert.ToInt32(e.Result) > 0)
            {
                MessageBox.Show("注册成功！恭喜你！", "注册", MessageBoxButton.OK);
              
            }
        }
        public void BeginLogin(string username, string pwd, TextBlock tbIn)
        {
            tb = tbIn;
            Username = username;
            client = new LoginAndResisterClient();
            client.QuerySQLCompleted += client_QuerySQLCompleted;
            client.QuerySQLAsync(username, pwd);
        }
        void client_QuerySQLCompleted(object sender, QuerySQLCompletedEventArgs e)
        {
            List<Information> inforList = new List<Information>();
            using (XmlReader xReader = XmlReader.Create(new StringReader(e.Result)))
            {
                inforList.Clear();
                //XmlReader读取XML数据
                while (xReader.ReadToFollowing("Table"))
                {
                    xReader.ReadToDescendant("Id");
                    int Id = xReader.ReadElementContentAsInt();
                    xReader.ReadToDescendant("Name");
                    string name = xReader.ReadContentAsString();
                    xReader.ReadToDescendant("Password");
                    string pwd = xReader.ReadContentAsString();
                    Information carlocation = new Information() { Id = Id, Name = name, Pwd = pwd };
                    inforList.Add(carlocation);
                }
            }
            if (inforList.Count > 0)
            {
                MessageBox.Show("登录成功！恭喜你！", "登录", MessageBoxButton.OK);
                tb.Text = Username+"欢迎你";
            }
            else
                MessageBox.Show("登录失败！", "登录", MessageBoxButton.OK);  
        }
        public class Information
        {
            public int Id { get; set; }
            public string Name { get; set; }
            public string Pwd { get; set; }
        }
    }
}

  private void btnLogin_Click(object sender, RoutedEventArgs e)
         {
             UsersManageClass usermanage = new UsersManageClass();
             usermanage.BeginLogin(txtName.Text.Trim(), txtPwd.Password.Trim(),tbLogin);
         }
         
         private void btnRegister_Click(object sender, RoutedEventArgs e)
         {          
             UsersManageClass usermanage = new UsersManageClass();
             usermanage.BeginRegister(txtName.Text.Trim(), txtPwd.Password.Trim());
         }
        

using System;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Runtime.Serialization;
using System.ServiceModel;
using System.Text;

namespace Test1.Web.APPData
{
    // 注意: 使用“重构”菜单上的“重命名”命令，可以同时更改代码、svc 和配置文件中的类名“login”。
    // 注意: 为了启动 WCF 测试客户端以测试此服务，请在解决方案资源管理器中选择 login.svc 或 login.svc.cs，然后开始调试。
    public class Login : ILogin
    {
        SqlConnection strCon = new SqlConnection(@"server=.MySql;database=AnJuKe_DB;user id=sa;password=123;");
        //server=SQLServer服务器名称;database=数据库名称;uid=用户名;pwd=密码"
        public void OpenSQL()
        {
            strCon.Open();
        }

        public void CloseSQL()
        {
            strCon.Close();
        }
        public string QuerySQL(string UserName,string pwd)
        {
            try
            {
                OpenSQL();
                string strSql = string.Format("select * from T_Users where Name like '%{0}%' and Password like '%{1}%'",UserName,pwd);
                DataSet ds = new DataSet();
                SqlDataAdapter s = new SqlDataAdapter(strSql, strCon);
                s.Fill(ds);
                return ds.GetXml();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();
            }
        }
        public int  AddUsers(string Username, string pwd)
        {
          
            try
            {              
                OpenSQL();
                string strInsert = "insert into T_Users values('"+Username +"','"+pwd+"')";
                SqlCommand cmd = new SqlCommand(strInsert, strCon);
             return  cmd.ExecuteNonQuery();              
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();               
            }

        }
        public int UpdateUsers(string Username, string pwd)
        {

            try
            {
                OpenSQL();
                string strUpdate = "UPDATE T_Users SET Password = '"+pwd+"' WHERE Name = '"+Username+"'";
                SqlCommand cmd = new SqlCommand(strUpdate, strCon);
              return  cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();
            }
        }
        public int DeleteUsers(string Username)
        {
            try
            {
                OpenSQL();
                string strDelete = "delete from T_Users where Name='"+Username+"'";               
                SqlCommand cmd = new SqlCommand(strDelete, strCon);
                return cmd.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                CloseSQL();
            }
        }
    }
}