unit uQuery;

{$WARN SYMBOL_PLATFORM OFF}

interface

uses
  Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
  ComServ, ComObj, VCLCom, StdVcl, bdemts, DataBkr, DBClient,
  MtsRdm, Mtx, pQuery_TLB, DB, ADODB, uPublic, Provider;

type
  TxzBooksQuery = class(TMtsDataModule, IxzBooksQuery)
    ADOConnection1: TADOConnection;
    adsUerBooks: TADODataSet;
    adsBooksFromJSB: TADODataSet;
    adsBooksFromBooks: TADODataSet;
    dspUserBooks: TDataSetProvider;
    dspBooksFromBooks: TDataSetProvider;
    dspBooksFromJSB: TDataSetProvider;
    adoUser: TADODataSet;
    dspUser: TDataSetProvider;
    adsJSB: TADODataSet;
    adsBooks: TADODataSet;
    dspJSB: TDataSetProvider;
    dspBooks: TDataSetProvider;
  private
    { Private declarations }
  protected
    class procedure UpdateRegistry(Register: Boolean; const ClassID, ProgID: string); override;
    procedure QueryFromBooksByBookID(const ID: WideString;
      var vResult: OleVariant); safecall;
    procedure QueryFromJSBByUserID(const ID: WideString;
      var vResult: OleVariant); safecall;
    procedure QureyFromJSBByBookID(const ID: WideString;
      var vResult: OleVariant); safecall;
    procedure GetBooks(const Number, OwnerData: WideString;
      var vResult: OleVariant); safecall;
    procedure GetJSB(const Number, OwnerData: WideString;
      var vResult: OleVariant); safecall;
    procedure GetUser(const Number, OwnerData: WideString;
      var vResult: OleVariant); safecall;
  public
    { Public declarations }
  end;

var
  xzBooksQuery: TxzBooksQuery;

implementation

{$R *.DFM}

class procedure TxzBooksQuery.UpdateRegistry(Register: Boolean; const ClassID, ProgID: string);
begin
  if Register then
  begin
    inherited UpdateRegistry(Register, ClassID, ProgID);
    EnableSocketTransport(ClassID);
    EnableWebTransport(ClassID);
  end else
  begin
    DisableSocketTransport(ClassID);
    DisableWebTransport(ClassID);
    inherited UpdateRegistry(Register, ClassID, ProgID);
  end;
end;

procedure TxzBooksQuery.QueryFromBooksByBookID(const ID: WideString;
  var vResult: OleVariant);
begin
  try
    if ADOConnection1.Connected then
      ADOConnection1.Connected :=False;
    ADOConnection1.ConnectionString:=GetConStr;
    adsBooksFromBooks.Close;
    adsBooksFromBooks.Parameters.ParamByName('aid').Value :=id;
    adsBooksFromBooks.Open;
    if not adsBooksFromBooks.IsEmpty then
      vResult:=dspBooksFromBooks.Data;
  finally
    adsBooksFromBooks.Close;
  end;
end;

procedure TxzBooksQuery.QueryFromJSBByUserID(const ID: WideString;
  var vResult: OleVariant);
begin
  try
    if ADOConnection1.Connected then
      ADOConnection1.Connected :=False;
    ADOConnection1.ConnectionString:=GetConStr;
    adsUerBooks.Close;
    adsUerBooks.Parameters.ParamByName('aid').Value :=id;
    adsUerBooks.Open;
    if not adsUerBooks.IsEmpty then
      vResult:=dspUserBooks.Data;
  finally
    adsUerBooks.Close;
  end;
end;

procedure TxzBooksQuery.QureyFromJSBByBookID(const ID: WideString;
  var vResult: OleVariant);
begin
  try
    if ADOConnection1.Connected then
      ADOConnection1.Connected :=False;
    ADOConnection1.ConnectionString:=GetConStr;
    adsBooksFromJSB.Close;
    adsBooksFromJSB.Parameters.ParamByName('aid').Value :=id;
    adsBooksFromJSB.Open;
    if not adsBooksFromJSB.IsEmpty then
      vResult:=dspBooksFromJSB.Data;
  finally
    adsBooksFromJSB.Close;
  end;
end;

procedure TxzBooksQuery.GetBooks(const Number, OwnerData: WideString;
  var vResult: OleVariant);
begin
  //6
  try
    if ADOConnection1.Connected then
      ADOConnection1.Connected :=False;
    ADOConnection1.ConnectionString:=GetConStr;
    adsBooks.Close;
    adsBooks.CommandText:='select top '+ number +
      ' ID,Name,Author,Pub,Money,RKRQ,YJC,Times from 圖書(shū)庫(kù) where id>:aid';
    adsBooks.Parameters.ParamByName('aid').Value :=OwnerData;
    adsBooks.Open;
    vResult:=dspBooks.Data;
  except
    raise;
  end;
end;

procedure TxzBooksQuery.GetJSB(const Number, OwnerData: WideString;
  var vResult: OleVariant);
begin

end;

procedure TxzBooksQuery.GetUser(const Number, OwnerData: WideString;
  var vResult: OleVariant);
begin

end;

initialization
  TComponentFactory.Create(ComServer, TxzBooksQuery,
    Class_xzBooksQuery, ciMultiInstance, tmApartment);
end.