udmsgupdateserver.pas

delphi多层应用系统 delphi多层应用系统

unit udmsgUpdateServer;

interface

uses
  Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
  ComServ, ComObj, VCLCom, StdVcl, DataBkr, DBClient, PsgUpdateServer_TLB,
  Provider, Db, DBTables;

type
  TSingleUpdate = class(TRemoteDataModule, ISingleUpdate)
    Database1: TDatabase;
    Query1: TQuery;
    Query2: TQuery;
    Query2EMP_NO: TSmallintField;
    Query2FIRST_NAME: TStringField;
    Query2LAST_NAME: TStringField;
    Query2PHONE_EXT: TStringField;
    Query2HIRE_DATE: TDateTimeField;
    Query2DEPT_NO: TStringField;
    Query2JOB_CODE: TStringField;
    Query2JOB_GRADE: TSmallintField;
    Query2JOB_COUNTRY: TStringField;
    Query2SALARY: TFloatField;
    Query2FULL_NAME: TStringField;
    sgUpdateSQLProvider: TDataSetProvider;
    sgUpdateDataSetProvider: TDataSetProvider;
    procedure sgUpdateSQLProviderBeforeUpdateRecord(Sender: TObject;
      SourceDS: TDataSet; DeltaDS: TClientDataSet; UpdateKind: TUpdateKind;
      var Applied: Boolean);
    procedure sgUpdateSQLProviderUpdateData(Sender: TObject;
      DataSet: TClientDataSet);
    procedure Query2BeforePost(DataSet: TDataSet);
    procedure Query2AfterPost(DataSet: TDataSet);
  private
    { Private declarations }
  public
    { Public declarations }
  protected
    function Get_sgUpdateSQLProvider: IProvider; safecall;
    function Get_sgUpdateDataSetProvider: IProvider; safecall;
  end;

var
  SingleUpdate: TSingleUpdate;

implementation

uses fsgUpdateServerMain;

{$R *.DFM}


procedure TSingleUpdate.sgUpdateSQLProviderBeforeUpdateRecord(
  Sender: TObject; SourceDS: TDataSet; DeltaDS: TClientDataSet;
  UpdateKind: TUpdateKind; var Applied: Boolean);
var
  iCount : Integer;
begin
  for iCount := 0 to DeltaDS.RecordCount - 1 do
  begin
    if (pfInUpdate in DeltaDS.FieldByName('EMP_NO').ProviderFlags) then
    begin
      DeltaDS.FieldByName('EMP_NO').ProviderFlags := DeltaDS.FieldByName('EMP_NO').ProviderFlags - [pfInUpdate];
    end;
  end;
end;

procedure TSingleUpdate.sgUpdateSQLProviderUpdateData(Sender: TObject;
  DataSet: TClientDataSet);
var
  iCount, iCount1 : Integer;
begin
  Form1.ClientDataSet1.Data := DataSet.Data;

  for iCount1 := 0 to DataSet.FieldCount - 1 do
  begin
    Form1.StringGrid1.Cells[iCount1, 0] := DataSet.Fields[iCount1].FieldName;
  end;

  for iCount := 0 to DataSet.RecordCount - 1 do
  begin
    for iCount1 := 0 to DataSet.FieldCount - 1 do
    begin
      if (pfInUpdate in DataSet.Fields[iCount1].ProviderFlags) then
        Form1.StringGrid1.Cells[iCount1, iCount + 1] := Form1.StringGrid1.Cells[iCount1, iCount + 1] + 'pfInUpdate';
      if (pfInWhere in DataSet.Fields[iCount1].ProviderFlags) then
        Form1.StringGrid1.Cells[iCount1, iCount + 1] := Form1.StringGrid1.Cells[iCount1, iCount + 1] + 'pfInWhere';
      if (pfInKey in DataSet.Fields[iCount1].ProviderFlags) then
        Form1.StringGrid1.Cells[iCount1, iCount + 1] := Form1.StringGrid1.Cells[iCount1, iCount + 1] + 'pfInKey';
      if (pfHidden in DataSet.Fields[iCount1].ProviderFlags) then
        Form1.StringGrid1.Cells[iCount1, iCount + 1] := Form1.StringGrid1.Cells[iCount1, iCount + 1] + 'pfHidden';
    end;
  end;
end;

procedure TSingleUpdate.Query2BeforePost(DataSet: TDataSet);
begin
  Form1.StatusBar1.Panels[0].Text := 'BeforePost牟祇