经过两天时间的开源，感谢网友提出一些修改意见，特别是在XE中，做了一部分优化。

 

可以在SVN中下载到最新的代码

 

https://code.google.com/p/diocp/

今天做了一个操作数据库的演示<这里我拿出我在实际项目中操作数据库的方法，集成在Demo中>

 

操作数据库比较简单,分两部分功能，第一部分打开SQL

procedure TfrmMain.btnOpenSQLClick(Sender: TObject);var  lvJSonStream, lvRecvObject:TJsonStream;  lvStream:TStream;  lvData:AnsiString;  l, j, x:Integer;begin  lvJSonStream := TJsonStream.Create;  try    lvJSonStream.JSon := SO();    lvJSonStream.JSon.I['cmdIndex'] := 1001;   //打开一个SQL脚本，获取数据    lvJSonStream.Json.S['sql'] := mmoSQL.Lines.Text;    FClientSocket.sendObject(lvJSonStream);  finally    lvJSonStream.Free;  end;  //读取数据  lvRecvObject := TJsonStream.Create;  try    FClientSocket.recvObject(lvRecvObject);    if not lvRecvObject.getResult then    begin      raise Exception.Create(lvRecvObject.getResultMsg);    end;    SetLength(lvData, lvRecvObject.Stream.Size);    lvRecvObject.Stream.Position := 0;    lvRecvObject.Stream.ReadBuffer(lvData[1], lvRecvObject.Stream.Size);    cdsMain.XMLData := lvData;  finally     lvRecvObject.Free;  end;end;

服务端ClientContext中的处理

procedure TClientContext.dataReceived(const pvDataObject:TObject);var  lvJsonStream:TJSonStream;  lvFile:String;  lvCmdIndex:Cardinal;  lvXMLData, lvEncodeData:AnsiString;  lvSQL:String;begin  lvJsonStream := TJSonStream(pvDataObject);  lvCmdIndex := lvJsonStream.JSon.I['cmdIndex'];  //echo测试  if lvCmdIndex= 1000 then  begin    InterlockedIncrement(TesterINfo.__RecvTimes);    //回写数据    writeObject(lvJsonStream);  end else if lvCmdIndex = 1001 then  begin  //根据sql获取一个数据，放在Stream中    try      lvSQL := lvJsonStream.Json.S['sql'];      lvXMLData := dmMain.CDSProvider.QueryXMLData(lvSQL);      lvJsonStream.Clear();      lvJsonStream.Stream.WriteBuffer(lvXMLData[1], Length(lvXMLData));      lvJsonStream.setResult(True);    except      on e:Exception do      begin        lvJsonStream.Clear();        lvJsonStream.setResult(False);        lvJsonStream.setResultMsg(e.Message);      end;    end;        //回写数据    writeObject(lvJsonStream);

 

保存数据用到一个非常好用的DLL

客户端:

procedure TfrmMain.btnPostClick(Sender: TObject);var  lvJSonStream, lvRecvObject:TJsonStream;  lvStream:TStream;  lvData:AnsiString;  l, j, x:Integer;begin  if cdsMain.State in [dsInsert, dsEdit] then cdsMain.Post;    if cdsMain.ChangeCount = 0 then  begin    ShowMessage('没有做任何修改!');    exit;  end;  lvJSonStream := TJsonStream.Create;  try    lvJSonStream.JSon := SO();    lvJSonStream.JSon.I['cmdIndex'] := 1002;   //打开一个SQL脚本，获取数据    //打包修改记录    with TCDSOperatorWrapper.createCDSEncode do    begin      setTableINfo(PAnsiChar(AnsiString(edtUpdateTable.Text)), PAnsiChar(AnsiString(edtKeyFields.Text)));      setData(cdsMain.Data, cdsMain.Delta);      //执行编码      Execute;      lvData := getPackageData;    end;    mmoData.Clear;    mmoData.Lines.Add(lvData);    lvJSonStream.Stream.Write(lvData[1], Length(lvData));    FClientSocket.sendObject(lvJSonStream);  finally    lvJSonStream.Free;  end;  //读取数据  lvRecvObject := TJsonStream.Create;  try    FClientSocket.recvObject(lvRecvObject);    if not lvRecvObject.getResult then    begin      raise Exception.Create(lvRecvObject.getResultMsg);    end else    begin      ShowMessage('保存成功!');    end;  finally     lvRecvObject.Free;  end;  cdsMain.MergeChangeLog();end;

服务端:

if lvCmdIndex = 1002 then  //保存数据到熟客  begin    try      lvJsonStream.Stream.Position := 0;      SetLength(lvEncodeData, lvJSonStream.Stream.Size);      lvJsonStream.Stream.ReadBuffer(lvEnCodeData[1], lvJSonStream.Stream.Size);      dmMain.ExecuteApplyUpdate(lvEncodeData);      lvJsonStream.Clear();      lvJsonStream.setResult(True);    except      on e:Exception do      begin        lvJsonStream.Clear();        lvJsonStream.setResult(False);        lvJsonStream.setResultMsg(e.Message);      end;    end;        //回写数据    writeObject(lvJsonStream);  end