} } }

    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



    读书,不要想着实用,更不要有功利心。读书只为了自身的修养。邂逅一本好书如同邂逅一位知己,邂逅一个完美之人。有时心生敬意,有时怦然心动。仿佛你心底埋藏多年的话,作者替你说了出来,你们在时光深处倾心相遇的一瞬间,情投意合,心旷神怡。
    分享到: