rmd_sqldir.pas

来自「胜天进销存源码,国产优秀的进销存」· PAS 代码 · 共 606 行 · 第 1/2 页

end;

procedure TRMDSDQuery.LoadFromStream(aStream: TStream);
begin
  inherited LoadFromStream(aStream);
  RMReadWord(aStream);
  FQuery.DetachOnFetchAll := RMReadBoolean(aStream);
  FQuery.ParamCheck := RMReadBoolean(aStream);
  FQuery.Preservation := RMReadBoolean(aStream);
  FQUery.SessionName := RMReadString(aStream);
end;

procedure TRMDSDQuery.SaveToStream(aStream: TStream);
begin
  inherited SaveToStream(aStream);
  RMWriteWord(aStream, 0);
  RMWriteBoolean(aStream, FQuery.DetachOnFetchAll);
  RMWriteBoolean(aStream, FQuery.ParamCheck);
  RMWriteBoolean(aStream, FQuery.Preservation);
  RMWriteString(aStream, FQUery.SessionName);
end;

procedure TRMDSDQuery.GetDatabases(sl: TStrings);
var
  liStringList: TStringList;
begin
  liStringList := TStringList.Create;
  try
    FQuery.DBSession.GetDatabaseNames(liStringList);
    liStringList.Sort;
    sl.Assign(liStringList);
  finally
    liStringList.Free;
  end;
end;

procedure TRMDSDQuery.GetTableNames(DB: string; Strings: TStrings);
var
  sl: TStringList;
begin
  sl := TStringList.Create;
  try
    try
      FQuery.DBSession.GetTableNames(FQuery.DatabaseName, '', False, sl);
      sl.Sort;
      Strings.Assign(sl);
    except;
    end;
  finally
    sl.Free;
  end;
end;

procedure TRMDSDQuery.GetTableFieldNames(const DB, TName: string; sl: TStrings);
var
  lStrings: TStringList;
begin
  lStrings := TStringList.Create;
  try
    FQuery.DBSession.GetTableFieldNames(FQuery.DatabaseName, TName, lStrings);
    lStrings.Sort;
    sl.Assign(lStrings);
  finally
    lStrings.Free;
  end;
end;

function TRMDSDQuery.GetParamName(Index: Integer): string;
begin
  Result := FQuery.Params[Index].Name;
end;

function TRMDSDQuery.GetParamType(Index: Integer): TFieldType;
begin
  Result := FQuery.Params[Index].DataType;
end;

procedure TRMDSDQuery.SetParamType(Index: Integer; Value: TFieldType);
begin
  FQuery.Params[Index].DataType := Value;
end;

function TRMDSDQuery.GetParamKind(Index: Integer): TRMParamKind;
begin
  Result := rmpkValue;
  if not FQuery.Params[Index].Bound then
    Result := rmpkAssignFromMaster;
end;

procedure TRMDSDQuery.SetParamKind(Index: Integer; Value: TRMParamKind);
begin
  if Value = rmpkAssignFromMaster then
  begin
    FQuery.Params[Index].Bound := False;
    FParams.Delete(FParams.IndexOf(FQuery.Params[Index].Name));
  end
  else
  begin
    FQuery.Params[Index].Clear;
    FQuery.Params[Index].Bound := True;
    FParams[FQuery.Params[Index].Name] := '';
  end;
end;

function TRMDSDQuery.GetParamText(Index: Integer): string;
var
  v: Variant;
begin
  v := '';
  if ParamKind[Index] = rmpkValue then
    v := FParams[FQuery.Params[Index].Name];
  if v = Null then
    v := '';
  Result := v;
end;

procedure TRMDSDQuery.SetParamText(Index: Integer; Value: string);
begin
  if ParamKind[Index] = rmpkValue then
    FParams[FQuery.Params[Index].Name] := Value;
end;

function TRMDSDQuery.GetParamValue(Index: Integer): Variant;
begin
  Result := FQuery.Params[Index].Value;
end;

procedure TRMDSDQuery.SetParamValue(Index: Integer; Value: Variant);
begin
  FQuery.Params[Index].Value := Value;
end;

function TRMDSDQuery.GetParamCount: Integer;
begin
  Result := FQuery.ParamCount;
end;

function TRMDSDQuery.GetSQL: string;
begin
  Result := FQuery.SQL.Text;
end;

procedure TRMDSDQuery.SetSQL(Value: string);
begin
  FQuery.SQL.Text := Value;
end;

function TRMDSDQuery.GetFilter: string;
begin
  Result := FQuery.Filter;
end;

procedure TRMDSDQuery.SetFilter(Value: string);
begin
  FQuery.Filter := Value;
end;

function TRMDSDQuery.GetDatabaseName: string;
begin
  Result := FQuery.DatabaseName;
end;

procedure TRMDSDQuery.SetDatabaseName(const Value: string);
begin
  FQuery.DatabaseName := Value;
end;

function TRMDSDQuery.GetDataSource: string;
begin
  Result := RMGetDataSetName(FQuery.Owner, FQuery.DataSource)
end;

procedure TRMDSDQuery.SetDataSource(Value: string);
var
  lComponent: TComponent;
begin
  lComponent := RMFindComponent(FQuery.Owner, Value);
  if (lComponent <> nil) and (lComponent is TDataSet) then
    FQuery.DataSource := RMGetDataSource(FQuery.Owner, TDataSet(lComponent))
  else
    FQuery.DataSource := nil;
end;


{------------------------------------------------------------------------------}
{------------------------------------------------------------------------------}
{------------------------------------------------------------------------------}
{------------------------------------------------------------------------------}

type
  TSessionNameEditor = class(TELStringPropEditor)
  protected
    function GetAttrs: TELPropAttrs; override;
    procedure GetValues(AValues: TStrings); override;
  end;

  TDatabaseParamsEditor = class(TELStringPropEditor)
  protected
    function GetAttrs: TELPropAttrs; override;
    procedure Edit; override;
  end;

  TQueryDatabaseNameEditor = class(TELStringPropEditor)
  protected
    function GetAttrs: TELPropAttrs; override;
    procedure GetValues(AValues: TStrings); override;
  end;

{------------------------------------------------------------------------------}
{------------------------------------------------------------------------------}
{ TSessionNameEditor }

function TSessionNameEditor.GetAttrs: TELPropAttrs;
begin
  Result := [praValueList, praSortList];
end;

procedure TSessionNameEditor.GetValues(AValues: TStrings);
begin
  SDEngine.Sessions.GetSessionNames(AValues);
end;

{------------------------------------------------------------------------------}
{------------------------------------------------------------------------------}
{}

function TDatabaseParamsEditor.GetAttrs: TELPropAttrs;
begin
  Result := [praDialog];
end;

procedure TDatabaseParamsEditor.Edit;
var
  tmp: TELStringsEditorDlg;
begin
  tmp := TELStringsEditorDlg.Create(nil);
  try
    tmp.Lines.Assign(TRMDSDDatabase(GetInstance(0)).Params);
    if tmp.ShowModal = mrOK then
    begin
      TRMDSDDatabase(GetInstance(0)).Params.Assign(tmp.Lines);
    end;
  finally
    tmp.Free;
  end;
end;

{------------------------------------------------------------------------------}
{------------------------------------------------------------------------------}
{ TQueryDatabaseNameEditor }

function TQueryDatabaseNameEditor.GetAttrs: TELPropAttrs;
begin
  Result := [praValueList, praSortList];
end;

procedure TQueryDatabaseNameEditor.GetValues(AValues: TStrings);
begin
  try
    RMGetComponents(RMDialogForm, TSDDatabase, AValues, nil);
  finally
  end;
end;

procedure RM_RegisterRAI2Adapter(RAI2Adapter: TJvInterpreterAdapter);
begin
  with RAI2Adapter do
  begin
    AddClass('ReportMachine', TRMDSDDatabase, 'TRMDSDDatabase');
    AddClass('ReportMachine', TRMDSDQuery, 'TRMDSDQuery');

    AddConst('ReportMachine', 'stDB2', stDB2);
    AddConst('ReportMachine', 'stInformix', stInformix);
    AddConst('ReportMachine', 'stInterbase', stInterbase);
    AddConst('ReportMachine', 'stMySQL', stMySQL);
    AddConst('ReportMachine', 'stODBC', stODBC);
    AddConst('ReportMachine', 'stOracle', stOracle);
    AddConst('ReportMachine', 'stSQLBase', stSQLBase);
    AddConst('ReportMachine', 'stSQLServer', stSQLServer);
    AddConst('ReportMachine', 'stSybase', stSybase);
    AddConst('ReportMachine', 'tiDirtyRead', tiDirtyRead);
    AddConst('ReportMachine', 'tiReadCommitted', tiReadCommitted);
    AddConst('ReportMachine', 'tiRepeatableRead2', tiRepeatableRead);
    AddConst('ReportMachine', 'stDB2', stDB2);
    AddConst('ReportMachine', 'stDB2', stDB2);

    RMRegisterPropEditor(TypeInfo(string), TRMDSDDatabase, 'Params', TDatabaseParamsEditor);
    RMRegisterPropEditor(TypeInfo(string), TRMDSDDatabase, 'SessionName', TSessionNameEditor);

    RMRegisterPropEditor(TypeInfo(string), TRMDSDQuery, 'SessionName', TSessionNameEditor);
    RMRegisterPropEditor(TypeInfo(string), TRMDSDQuery, 'DatabaseName', TQueryDatabaseNameEditor);
  end;
end;

initialization
  RMRegisterControl(TRMDSDDatabase, 'RMD_SDDATABASEcontrol', 'SDDatabase');
  RMRegisterControl(TRMDSDQuery, 'RMD_SDQUERYCONTROL', 'SDQuery');

  RM_RegisterRAI2Adapter(GlobalJvInterpreterAdapter);

end.