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
读书,不要想着实用,更不要有功利心。读书只为了自身的修养。邂逅一本好书如同邂逅一位知己,邂逅一个完美之人。有时心生敬意,有时怦然心动。仿佛你心底埋藏多年的话,作者替你说了出来,你们在时光深处倾心相遇的一瞬间,情投意合,心旷神怡。
经过两天时候的开源,感激网友提出一些批改定见,希罕是在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
读书,不要想着实用,更不要有功利心。读书只为了自身的修养。邂逅一本好书如同邂逅一位知己,邂逅一个完美之人。有时心生敬意,有时怦然心动。仿佛你心底埋藏多年的话,作者替你说了出来,你们在时光深处倾心相遇的一瞬间,情投意合,心旷神怡。