经过两天时间的开源，感谢网友提出一些修改意见，特别是在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
