-
DIOCP开源项目-DEMO（怎么样操纵长途数据库）
添加时间:2013-5-21 点击量:经过两天时候的开源，感激网友提出一些批改定见，希罕是在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）;
//履行编码
ute;
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.uteApplyUpdate（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
读书，不要想着实用，更不要有功利心。读书只为了自身的修养。邂逅一本好书如同邂逅一位知己，邂逅一个完美之人。有时心生敬意，有时怦然心动。仿佛你心底埋藏多年的话，作者替你说了出来，你们在时光深处倾心相遇的一瞬间，情投意合，心旷神怡。
