Как использовать TSGE-класс BDE в Delphi?

Question

Я использую множественное соединение, используя ODBC. В целом проекте я использую одно и то же соединение, но создаю, использую и уничтожаю объект TQuery. Теперь я собираюсь использовать соединение в потоках и узнал, что Delphi BDE предоставляет для этого класс TSession. Я хочу знать, как использовать TSession для одновременной работы, пожалуйста, укажите образец кода, если это возможно.

Answer 1

Хотя я согласен с тем, что BDE является старым, можно создать потокобезопасный доступ к базе данных с использованием BDE и TSessions.

Рассмотрите это. Когда одновременно запускаются две копии одного и того же приложения, механизм базы данных или сервер баз данных различают два экземпляра для записи и блокировки таблиц. Это различие возможно, потому что каждое приложение использует отдельное соединение или в случае сеанса BDE.

Сессия представлена ​​экземпляром TSession. В однопоточных проектах TSession создан для вас. Если вы хотите подключиться к BDE с двумя или более потоками, каждый из них должен иметь свой собственный TSession.

Использование нескольких TSessions показано здесь, в этом действительно старом примере кода, который я откопал (он старый, и я бы сделал это по-другому сегодня, но вы его просили). Хитрость заключается в том, что каждый сеанс должен иметь один и тот же сетевой каталог и иметь уникальный частный каталог. Вот потомок TThread:

type 
    TWriteData = class(TThread) 
    private 
    FSQL: String; 
    FFileName: String; 
    protected 
    procedure Execute; override; 
    public 
    constructor Create(CreateSuspended: Boolean; const SQL: String; 
     const FileName: String); override; overload; 
    end; 

Вот переопределенный конструктор:

constructor TWriteData.Create(CreateSuspended: Boolean; 
const SQL: String; const FileName: String); 
begin 
    inherited Create(True); 
    FSQL := SQL; 
    FFileName := String; 
end; 

А вот метод выполнения. Важно отметить, что TSession.PrivateDir установлен в уникальное имя каталога (на основе ThreadID). Также можно использовать GUID или другое значение, если оно уникально. Также обратите внимание, что Session1 является компонентом TSession в модуле данных, а Query1 является TQuery, который использует TDatabase (Database1), который, в свою очередь, использует Session1. Сессия - это переменная, объявленная в блоке Bde.DBTables. Эта переменная относится к TSGE по умолчанию, который BDE создает для BDE TDataSets, которые активны в основном потоке выполнения.

procedure TWriteData.Execute; 
var 
    DataMod: TDataModule1; 
    AppDir: String; 
begin 
    AppDir := ExtractFilePath(Application.ExeName); 
    DataMod := TDataModule1.Create(nil); 
    try 
    with DataMod do 
     begin 
     //All sessions need a unique private directory 
     Session1.PrivateDir := AppDir + IntToStr(Self.ThreadID); 
     //All sessions share a common network control file 
     Session1.NetFileDir := Session.NetFileDir; 
     ForceDirectories(Session1.PrivateDir); 
     try 
      Query1.SQL.Text := FSQL; 
      ClientDataSet1.Open; 
      ClientDataSet1.SaveToFile(AppDir + FFileName); 
      ClientDataSet1.Close; 
     finally 
      SysUtils.RemoveDir(Session1.PrivateDir); 
     end; //try 
     end; //begin 
    finally 
    DataMod.Free; 
    end; 
end; 

Надеюсь, это поможет.