第1章 系统总体结构
1.1 总体结构图
系统实现需要部署服务器端的远程对象(即一个DbServerLibrary.dll),服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器,同时根据SQL解析的结果向各个服务器发送命令,并将结果显示在客户端界面,服务器端可以接受并显示相应的命令。系统结构如下所示:
1.1 总体结构图
系统实现需要部署服务器端的远程对象(即一个DbServerLibrary.dll),服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器,同时根据SQL解析的结果向各个服务器发送命令,并将结果显示在客户端界面,服务器端可以接受并显示相应的命令。系统结构如下所示:
说明:服务器分别为:219.224.49.108(数据库为DDB)和219.224.49.82(数据库为DDB),因资源限制,客户端也部署在219.224.49.82上,但是数据库为DDBS。
1.2 关键组件结构图
系统结构中关键的组件有远程对象,和本地服务器,实现的功能基本一致。下面以远程
对象为例,说明组件的实现。远程对象在服务器端解决方案下的库文件中声明,通过服务器端进行注册,客户端通过TCP通道与服务器端远程对象通信,实现数据集的查询和传输。主要的数据成员有:SqlConnection(SQL Server数据库的连接对象)、 SqlCommand (SQL命令对象)、SqlDataAdapter(数据适配器,填充数据集)
组件——DbServerLibrary:
第2 章 数据字典结构
因时间仓促,未实现数据字典,所有实验要求的SQL经过解析后,直接通过代码判断,向相应场地发送命令。
第3 章 代码结构
代码分为三部分:远程对象,服务器端代码和客户端代码。
其中:远程对象部署在各个服务器端,客户端除了实现查询命令的解析和传送外
外,还有一个本地服务器,进行相应的本地查询。
远程对象代码:
using System;
using System.Runtime.Serialization;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace DbServerLibrary
{
[SerializableAttribute] //It is very important for Remoting Data
public class DbServer : MarshalByRefObject
{
private string connStr;
private string clientSql;
public SqlConnection sqlConn;
public SqlCommand sqlComm;
public SqlDataAdapter sqlAdapter;
public void GetClientSql(string sql)
{
if(clientSql != null)
{
clientSql = null;
}
clientSql = sql;
MessageBox.Show(clientSql);
}
public DbServer()
{
//LocalData Initialize
connStr = "Data Source = localhost;Initial Catalog=DDB;User ID=sa;Password=;";
sqlConn = new SqlConnection(connStr);
}
public DataSet GetDataSet() // 执行select
{
DataSet ds = new DataSet();
if (sqlComm != null)
{
sqlComm = null;
}
if(sqlConn.State == ConnectionState.Closed)
{
sqlConn.Open();
}
try
{
sqlComm = new SqlCommand();
sqlComm.Connection = sqlConn;
sqlComm.CommandText = clientSql;
sqlComm.CommandType = CommandType.Text;
sqlAdapter = new SqlDataAdapter();
sqlAdapter.SelectCommand = sqlComm;
sqlAdapter.Fill(ds);
}
catch(SqlException ex)
{
MessageBox.Show(ex.Message);
}
return ds;
}
public int ExecuteSql() //执行insert和delete
{
int affectedNumber;
if (sqlComm != null)
{
sqlComm = null;
}
if(sqlConn.State == ConnectionState.Closed)
{
sqlConn.Open();
}
try
{
sqlComm = new SqlCommand();
sqlComm.Connection = sqlConn;
sqlComm.CommandType = CommandType.Text;
sqlComm.CommandText = clientSql;
affectedNumber = sqlComm.ExecuteNonQuery();
return affectedNumber;
}
catch(SqlException ex)
{
MessageBox.Show(ex.Message);
return 0;
}
}
}
}
服务器启动注册远程对象:
private void frmSupplierServer_Load(object sender, System.EventArgs e)
{
TcpChannel chan = new TcpChannel(8888);
ChannelServices.RegisterChannel(chan);
//注册提供服务的远程对象 RemotingConfiguration.RegisterWellKnownServiceType(typeof(DbServerLibrary.DbServer) ,"DbServer",WellKnownObjectMode.Singleton);
}
客户端解析SQL:SqlParse.cs
using System;
using System.Collections;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace SupplierClient
{
/// <summary>
/// SqlParse 的摘要说明。
/// </summary>
public class SqlParse
{
//得到sql语句的类型
public string GetSqlType(string sqlText) //type of SQL statements
{
string[] sqltype = sqlText.Split(' ');
if (sqltype[0].Equals("SELECT"))
{
return "SELECT";
}
else if (sqltype[0].Equals("INSERT"))
{
return "INSERT";
}
else if (sqltype[0].Equals("DELETE"))
{
return "DELETE";
}
else
{
return "OK";
}
}
//得到select语句要查询的表名
public string GetSelectTableName(string sqlText)
{
string tableName = null;
string[] sql = sqlText.Split(' ');
for (int i=1; i < sql.Length; i ++)
{
if(sql[i].Equals("FROM"))
{
tableName = sql[i+1];
}
}
return tableName;
}
//得到select语句中的where子句
public string GetWhereClause(string sqlText)
{
}
//得到查询条件中的字段名
public string GetSelectField(string sqlText)
{
}
//得到分片依据,返回Scity的值
public string GetSelectCityValue(string sqlText)
{
}
//设定select语句经解析后的格式
public ArrayList SetSelectList(string sqlText)
{
}
//如果没有分片信息,则向3个场地都发送命令
public ArrayList SendToAllSite(string sqlText)
{
}
//得到insert语句要查询的表名
public string GetInsertTableName(string sqlText)
{
}
//根据插入的表和值,设定场地
public string GetInsertCityValue(string sqlText)
{
}
//如果表名是Supplier,则根据city值设定向哪个场地发送命令
public ArrayList SetInsertSite(string sqlText)
{
}
//生成解析后的insert命令列表
public ArrayList SetInsertList(string sqlText)
{
}
}
}
本地服务器查询代码:LocalServer.cs
using System;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace SupplierClient
{
public class LocalServer
{
private SqlConnection sqlConn;
private SqlCommand sqlComm;
private SqlDataAdapter sqlAdapter;
public LocalServer()
{
sqlConn = new SqlConnection();
sqlConn.ConnectionString = "Data Source=ZYF;Initial Catalog=DDBS;User Id=sa;Password=;";
sqlConn.Open();
}
//返回查询结果
public DataSet MakeDataSet(string sqlText)
{
sqlAdapter = new SqlDataAdapter(sqlText,sqlConn);
DataSet ds = new DataSet();
try
{
sqlAdapter.Fill(ds);
return ds;
}
catch(SqlException ex)
{
MessageBox.Show(ex.Message);
return null;
}
finally
{
sqlConn.Dispose();
sqlAdapter.Dispose();
}
}
//执行插入和删除操作,并返回影响记录数
public int ExecuteSql(string sqlText)
{
try
{
sqlComm = new SqlCommand();
sqlComm.Connection = sqlConn;
sqlComm.CommandType = CommandType.Text;
sqlComm.CommandText = sqlText;
int affectedNumber = sqlComm.ExecuteNonQuery();
return affectedNumber;
}
catch (SqlException ex)
{
MessageBox.Show(ex.Message);
return 0;
}
}
}
}
{
if(clientSql != null)
{
clientSql = null;
}
clientSql = sql;
MessageBox.Show(clientSql);
}
public DbServer()
{
//LocalData Initialize
connStr = "Data Source = localhost;Initial Catalog=DDB;User ID=sa;Password=;";
sqlConn = new SqlConnection(connStr);
}
public DataSet GetDataSet() // 执行select
{
DataSet ds = new DataSet();
if (sqlComm != null)
{
sqlComm = null;
}
if(sqlConn.State == ConnectionState.Closed)
{
sqlConn.Open();
}
try
{
sqlComm = new SqlCommand();
sqlComm.Connection = sqlConn;
sqlComm.CommandText = clientSql;
sqlComm.CommandType = CommandType.Text;
sqlAdapter = new SqlDataAdapter();
sqlAdapter.SelectCommand = sqlComm;
sqlAdapter.Fill(ds);
}
catch(SqlException ex)
{
MessageBox.Show(ex.Message);
}
return ds;
}
public int ExecuteSql() //执行insert和delete
{
int affectedNumber;
if (sqlComm != null)
{
sqlComm = null;
}
if(sqlConn.State == ConnectionState.Closed)
{
sqlConn.Open();
}
try
{
sqlComm = new SqlCommand();
sqlComm.Connection = sqlConn;
sqlComm.CommandType = CommandType.Text;
sqlComm.CommandText = clientSql;
affectedNumber = sqlComm.ExecuteNonQuery();
return affectedNumber;
}
catch(SqlException ex)
{
MessageBox.Show(ex.Message);
return 0;
}
}
}
}
服务器启动注册远程对象:
private void frmSupplierServer_Load(object sender, System.EventArgs e)
{
TcpChannel chan = new TcpChannel(8888);
ChannelServices.RegisterChannel(chan);
//注册提供服务的远程对象 RemotingConfiguration.RegisterWellKnownServiceType(typeof(DbServerLibrary.DbServer) ,"DbServer",WellKnownObjectMode.Singleton);
}
客户端解析SQL:SqlParse.cs
using System;
using System.Collections;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace SupplierClient
{
/// <summary>
/// SqlParse 的摘要说明。
/// </summary>
public class SqlParse
{
//得到sql语句的类型
public string GetSqlType(string sqlText) //type of SQL statements
{
string[] sqltype = sqlText.Split(' ');
if (sqltype[0].Equals("SELECT"))
{
return "SELECT";
}
else if (sqltype[0].Equals("INSERT"))
{
return "INSERT";
}
else if (sqltype[0].Equals("DELETE"))
{
return "DELETE";
}
else
{
return "OK";
}
}
//得到select语句要查询的表名
public string GetSelectTableName(string sqlText)
{
string tableName = null;
string[] sql = sqlText.Split(' ');
for (int i=1; i < sql.Length; i ++)
{
if(sql[i].Equals("FROM"))
{
tableName = sql[i+1];
}
}
return tableName;
}
//得到select语句中的where子句
public string GetWhereClause(string sqlText)
{
}
//得到查询条件中的字段名
public string GetSelectField(string sqlText)
{
}
//得到分片依据,返回Scity的值
public string GetSelectCityValue(string sqlText)
{
}
//设定select语句经解析后的格式
public ArrayList SetSelectList(string sqlText)
{
}
//如果没有分片信息,则向3个场地都发送命令
public ArrayList SendToAllSite(string sqlText)
{
}
//得到insert语句要查询的表名
public string GetInsertTableName(string sqlText)
{
}
//根据插入的表和值,设定场地
public string GetInsertCityValue(string sqlText)
{
}
//如果表名是Supplier,则根据city值设定向哪个场地发送命令
public ArrayList SetInsertSite(string sqlText)
{
}
//生成解析后的insert命令列表
public ArrayList SetInsertList(string sqlText)
{
}
}
}
本地服务器查询代码:LocalServer.cs
using System;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace SupplierClient
{
public class LocalServer
{
private SqlConnection sqlConn;
private SqlCommand sqlComm;
private SqlDataAdapter sqlAdapter;
public LocalServer()
{
sqlConn = new SqlConnection();
sqlConn.ConnectionString = "Data Source=ZYF;Initial Catalog=DDBS;User Id=sa;Password=;";
sqlConn.Open();
}
//返回查询结果
public DataSet MakeDataSet(string sqlText)
{
sqlAdapter = new SqlDataAdapter(sqlText,sqlConn);
DataSet ds = new DataSet();
try
{
sqlAdapter.Fill(ds);
return ds;
}
catch(SqlException ex)
{
MessageBox.Show(ex.Message);
return null;
}
finally
{
sqlConn.Dispose();
sqlAdapter.Dispose();
}
}
//执行插入和删除操作,并返回影响记录数
public int ExecuteSql(string sqlText)
{
try
{
sqlComm = new SqlCommand();
sqlComm.Connection = sqlConn;
sqlComm.CommandType = CommandType.Text;
sqlComm.CommandText = sqlText;
int affectedNumber = sqlComm.ExecuteNonQuery();
return affectedNumber;
}
catch (SqlException ex)
{
MessageBox.Show(ex.Message);
return 0;
}
}
}
}
第4 章 界面
4.1 客户端
4.1 客户端
客户端启动后,用户首先在文本框中输入SQL命令,然后通过解析后向相应场地发送命令,并将返回的结果集进行合并,显示在界面中,显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。
4.2 服务器
服务器端仅实现对远程对象的注册,因此界面不需要实现功能,只需要在启动时注册远程对象即可,接收到的客户端的用户命令是通过消息框显示的。如上图所示。
第5 章 命令处理及核心算法流程
Insert 操作——
//得到insert语句要查询的表名
public string GetInsertTableName(string sqlText)
{
string tableName = null;
string[] sql = sqlText.Split(' ');
for (int i=1; i < sql.Length; i ++)
{
if(sql[i].Equals("INTO"))
{
tableName = sql[i+1];
}
}
return tableName;
}
Insert 操作——
//得到insert语句要查询的表名
public string GetInsertTableName(string sqlText)
{
string tableName = null;
string[] sql = sqlText.Split(' ');
for (int i=1; i < sql.Length; i ++)
{
if(sql[i].Equals("INTO"))
{
tableName = sql[i+1];
}
}
return tableName;
}
//根据插入的表和值,设定场地:INSERT INTO Supplier VALUES('no','name','city'),return city
public string GetInsertCityValue(string sqlText)
{
string tableName = GetInsertTableName(sqlText);
string[] city = sqlText.Split(',');
string cityName = city[2];
cityName = cityName.Substring(1,cityName.Length-3);
return cityName;
}
public string GetInsertCityValue(string sqlText)
{
string tableName = GetInsertTableName(sqlText);
string[] city = sqlText.Split(',');
string cityName = city[2];
cityName = cityName.Substring(1,cityName.Length-3);
return cityName;
}
//如果表名是Supplier,则根据city值设定向哪个场地发送命令
public ArrayList SetInsertSite(string sqlText)
{
string cityName = GetInsertCityValue(sqlText);
ArrayList insertArray = new ArrayList();
if(cityName.Equals("London"))
{
insertArray.Add(sqlText + "@Site1");
return insertArray;
}
else if(cityName.Equals("Paris"))
{
insertArray.Add(sqlText + "@Site2");
return insertArray;
}
else
{
insertArray.Add(sqlText + "@Site3");
return insertArray;
}
}
public ArrayList SetInsertSite(string sqlText)
{
string cityName = GetInsertCityValue(sqlText);
ArrayList insertArray = new ArrayList();
if(cityName.Equals("London"))
{
insertArray.Add(sqlText + "@Site1");
return insertArray;
}
else if(cityName.Equals("Paris"))
{
insertArray.Add(sqlText + "@Site2");
return insertArray;
}
else
{
insertArray.Add(sqlText + "@Site3");
return insertArray;
}
}
//生成解析后的insert命令列表
public ArrayList SetInsertList(string sqlText)
{
string tableName = GetInsertTableName(sqlText);
ArrayList insertArray = new ArrayList();
if(tableName.Equals("Supplier"))
{
insertArray = SetInsertSite(sqlText);
}
else
{
insertArray = SendToAllSite(sqlText);
}
return insertArray;
}
Delete 操作——
向各个场地发送,通过定义数据库中表的关系及约束来保证完整性和一致性,如果删除命令不成功,则返回异常信息,否则,返回各个场地成功执行命令影响的记录数目。
Select 操作——
//得到sql语句的类型
public string GetSqlType(string sqlText) //type of SQL statements
{
public ArrayList SetInsertList(string sqlText)
{
string tableName = GetInsertTableName(sqlText);
ArrayList insertArray = new ArrayList();
if(tableName.Equals("Supplier"))
{
insertArray = SetInsertSite(sqlText);
}
else
{
insertArray = SendToAllSite(sqlText);
}
return insertArray;
}
Delete 操作——
向各个场地发送,通过定义数据库中表的关系及约束来保证完整性和一致性,如果删除命令不成功,则返回异常信息,否则,返回各个场地成功执行命令影响的记录数目。
Select 操作——
//得到sql语句的类型
public string GetSqlType(string sqlText) //type of SQL statements
{
}
//得到select语句要查询的表名
public string GetSelectTableName(string sqlText)
{
public string GetSelectTableName(string sqlText)
{
}
//得到select语句中的where子句
public string GetWhereClause(string sqlText)
{
public string GetWhereClause(string sqlText)
{
}
//得到查询条件中的字段名
public string GetSelectField(string sqlText)
{
}
public string GetSelectField(string sqlText)
{
}
//得到分片依据,返回Scity的值
public string GetSelectCityValue(string sqlText)
{
public string GetSelectCityValue(string sqlText)
{
}
//设定select语句经解析后的格式
public ArrayList SetSelectList(string sqlText)
{
public ArrayList SetSelectList(string sqlText)
{
}
//如果没有分片信息,则向3个场地都发送命令
public ArrayList SendToAllSite(string sqlText)
{
//如果没有分片信息,则向3个场地都发送命令
public ArrayList SendToAllSite(string sqlText)
{
}
第6章 结论
第6章 结论
远程处理是.NET框架提供的一项强大的技术,利用它可以使位于任何位置的应用程序互相通信,这些应用程序可能在同一台计算机上运行,也可能位于同一局域网中的不同计算机上,或者位于相隔万里的有巨大差异的网络中。
使用.NET Remoting技术结合ADO.Net能够高效、可靠地解决这两方面的问题。具体表现为,在C#中通过使用.Net远程处理框架能够方便地解决数据、命令远程传递问题;C#通过ADO.Net对数据库进行操作,使分布式数据库系统中对数据库的各种操作变得高效、可靠,同时易于解决数据一致性问题。
由于时间关系,程序中仍有部分bug,将在下一步继续完善,而且,还应进一步完善数据字典,使程序结构更加清晰,增强可扩充性。
本文转自 august 51CTO博客,原文链接:http://blog.51cto.com/august/11812,如需转载请自行联系原作者