第1章系统总体结构
1.1 总体结构
系统实现需要部署服务器端的远程对象（即一个DbServerLibrary.dll），服务器端要注册通道和该远程对象。客户端要实现一个本地查询的服务器，同时根据SQL解析的结果向各个服务器发送命令，并将结果显示在客户端界面，服务器端可以接受并显示相应的命令。
1.2 关键组件结构
系统结构中关键的组件有远程对象，和本地服务器，实现的功能基本一致。下面以远程对象为例，说明组件的实现。远程对象在服务器端解决方案下的库文件中声明，通过服务器端进行注册，客户端通过TCP通道与服务器端远程对象通信，实现数据集的查询和传输。主要的数据成员有：SqlConnection（SQL Server数据库的连接对象）、 SqlCommand （SQL命令对象）、SqlDataAdapter（数据适配器，填充数据集）组件——DbServerLibrary。
第2 章.NET远程处理框架提供的强大技术
因时间仓促，未实现数据字典，所有实验要求的SQL经过解析后，直接通过代码判断，向相应场地发送命令。
代码分为三部分：远程对象，服务器端代码和客户端代码。
其中：远程对象部署在各个服务器端，客户端除了实现查询命令的解析和传送外外，还有一个本地服务器，进行相应的本地查询。
远程对象代码：
2 . usingSystem.Runtime.Serialization;
3 . usingSystem.Data;
4 . usingSystem.Data.SqlClient;
5 . usingSystem.Windows.Forms;
6 . namespaceDbServerLibrary{
7 . [SerializableAttribute] // ItisveryimportantforRemotingData
8 . publicclassDbServer:MarshalByRefObject{
9 . privatestringconnStr;
10 . privatestringclientSql;
11 . publicSqlConnectionsqlConn;
12 . publicSqlCommandsqlComm;
13 . publicSqlDataAdaptersqlAdapter;
14 . publicvoidGetClientSql(stringsql){
15 . if (clientSql != null ){
16 . clientSql = null ;
17 . }
18 . clientSql = sql;
19 . MessageBox.Show(clientSql);
20 . }
21 . publicDbServer(){
22 . // LocalDataInitialize
23 . cnnStr = " DataSource=localhost;InitialCatalog=DDB;UserID=sa;Password=; " ;
24 . sqlConn = newSqlConnection(connStr);
25 . }
26 . publicDataSetGetDataSet()
27 . // 执行select
28 . DataSetds = newDataSet();
29 . if (sqlComm != null ){
30 . sqlComm = null ;
31 . }
32 . if (sqlConn.State == ConnectionState.Closed){
33 . sqlConn.Open();
34 . }
35 . try {
36 . sqlComm = newSqlCommand();
37 . sqlComm.Connection = sqlConn;
38 . sqlComm.CommandText = clientSql;
39 . sqlComm.CommandType = CommandType.Text;
40 . sqlAdapter = newSqlDataAdapter();
41 . sqlAdapter.SelectCommand = sqlComm;
42 . sqlAdapter.Fill(ds);
43 . }
44 . catch (SqlExceptionex){
45 . MessageBox.Show(ex.Message);
46 . }
47 . returnds;
48 . }
49 . publicintExecuteSql() // 执行insert和delete{
50 . intaffectedNumber;
51 . if (sqlComm != null ){
52 . sqlComm = null ;
53 . }
54 . if (sqlConn.State == ConnectionState.Closed){
55 . sqlConn.Open();
56 . }
57 . try {
58 . sqlComm = newSqlCommand();
59 . sqlComm.Connection = sqlConn;
60 . sqlComm.CommandType = CommandType.Text;
61 . sqlComm.CommandText = clientSql;
62 . affectedNumber = sqlComm.ExecuteNonQuery();
63 . returnaffectedNumber;
64 . }
65 . catch (SqlExceptionex){
66 . MessageBox.Show(ex.Message);
67 . return0;
68 . }
69 . }
70 . }
71 . }
服务器端代码：
2 . {TcpChannelchan = newTcpChannel( 8888 );
3 . ChannelServices.RegisterChannel(chan);
4 . // 注册提供服务的远程对象
5 . RemotingConfiguration.RegisterWellKnownServiceType
( typeof (DbServerLibrary.DbServer)
" DbServer " ,WellKnownObjectMode.Singleton);
6 . }
客户端代码：
解析SQL：SqlParse.cs
2 . publicclassSqlParse{
3 . // 得到sql语句的类型
4 . publicstringGetSqlType(stringsqlText) // typeofSQLstatements{
5 . }
6 . // 得到select语句要查询的表名
7 . publicstringGetSelectTableName(stringsqlText){
8 . }
9 . // 得到select语句中的where子句
10 . publicstringGetWhereClause(stringsqlText){
11 . }
12 . // 得到查询条件中的字段名
13 . publicstringGetSelectField(stringsqlText){
14 . }
15 . // 得到分片依据，返回Scity的值
16 . publicstringGetSelectCityValue(stringsqlText){
17 . }
18 . // 设定select语句经解析后的格式
19 . publicArrayListSetSelectList(stringsqlText){
20 . }
21 . // 如果没有分片信息，则向3个场地都发送命令
22 . publicArrayListSendToAllSite(stringsqlText){
23 . }
24 . // 得到insert语句要查询的表名
25 . publicstringGetInsertTableName(stringsqlText){
26 . }
27 . // 根据插入的表和值，设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity
28 . publicstringGetInsertCityValue(stringsqlText){
29 . }
30 . // 如果表名是Supplier,则根据city值设定向哪个场地发送命令
31 . publicArrayListSetInsertSite(stringsqlText){
32 . }
33 . // 生成解析后的insert命令列表
34 . publicArrayListSetInsertList(stringsqlText){
35 . }
36 . namespaceSupplierClient{
37 . publicclassLocalServer{
38 . }
39 . // 返回查询结果
40 . publicDataSetMakeDataSet(stringsqlText){
41 . }
42 . // 执行插入和删除操作，并返回影响记录数
43 . publicintExecuteSql(stringsqlText){
44 . }
第4 章界面
4.1 客户端
客户端启动后，用户首先在文本框中输入SQL命令，然后通过解析后向相应场地发送命令，并将返回的结果集进行合并，显示在界面中，显示结果后空白的文本框用来显示执行插入删除操作时的结果信息。
4.2 服务器
服务器端仅实现对远程对象的注册，因此界面不需要实现功能，只需要在启动时注册远程对象即可，接收到的客户端的用户命令是通过消息框显示的。如上图所示。
第5 章命令处理及核心算法流程
Insert 操作——
2 . publicstringGetInsertTableName(stringsqlText){
3 . }
4 . // 根据插入的表和值，设定场地:INSERTINTOSupplierVALUES('no','name','city'),returncity
5 . publicstringGetInsertCityValue(stringsqlText){
6 . }
7 . // 如果表名是Supplier,则根据city值设定向哪个场地发送命令
8 . publicArrayListSetInsertSite(stringsqlText){
9 . }
10 . // 生成解析后的insert命令列表
11 . publicArrayListSetInsertList(stringsqlText){
12 . }
Delete 操作——
向各个场地发送，通过定义数据库中表的关系及约束来保证完整性和一致性，如果删除命令不成功，则返回异常信息，否则，返回各个场地成功执行命令影响的记录数目。
Select 操作——
2 . publicstringGetSqlType(stringsqlText) // typeofSQLstatements{
3 . }
4 . // 得到select语句要查询的表名
5 . publicstringGetSelectTableName(stringsqlText){
6 . }
7 . // 得到select语句中的where子句
8 . publicstringGetWhereClause(stringsqlText){
9 . }
10 . // 得到查询条件中的字段名
11 . publicstringGetSelectField(stringsqlText){
12 . }
13 . // 得到分片依据，返回Scity的值
14 . publicstringGetSelectCityValue(stringsqlText){
15 . }
16 . // 设定select语句经解析后的格式
17 . publicArrayListSetSelectList(stringsqlText){
18 . }
19 . // 如果没有分片信息，则向3个场地都发送命令
20 . publicArrayListSendToAllSite(stringsqlText){
21 . }
第6章结论
.NET远程处理框架提供的一项强大的技术，利用它可以使位于任何位置的应用程序互相通信，这些应用程序可能在同一台计算机上运行，也可能位于同一局域网中的不同计算机上，或者位于相隔万里的有巨大差异的网络中。
使用.NET Remoting技术结合ADO.Net能够高效、可靠地解决这两方面的问题。具体表现为，在C#中通过使用.Net远程处理框架能够方便地解决数据、命令远程传递问题；C#通过ADO.Net对数据库进行操作，使分布式数据库系统中对数据库的各种操作变得高效、可靠，同时易于解决数据一致性问题。
由于时间关系，程序中仍有部分bug，将在下一步继续完善，而且，还应进一步完善数据字典，使程序结构更加清晰，增强可扩充性。
