Delphi 数据库操作的简单封装

在日常开发中，经常会需要进行数据库操作，如执行一些 SQL 查询、或者执行一些 SQL 命令等，如果每次执行操作都按照 Delphi 数据库操作的步骤一步一步地组织语句去执行的话，又显得比较繁琐，所以，有必要对数据库的操作进行封装，以便于在进行数据库操作时，通过简单地调用即可实现。

在本节中，我们通过 Zeos 的数据库组件来实现一个简单的数据库操作封装。代码如下：

unit sqlunit;

{$mode ObjFPC}{$H+}

interface

uses
  Classes, SysUtils, ZConnection, ZDataset, DB, Dialogs;

type
  TSqlStatment = class
    private
      sSql: String;
    public
      Query: TZQuery;
      // 构造函数
      Constructor Create(Conn: TZConnection);
     
      procedure SetSQL(sql: String);
      procedure Execute;
      procedure Open;
      // 析构函数
      Destructor Free;
  end;

implementation

Constructor TSqlStatment.Create(Conn: TZConnection);
begin
  Query:=TZQuery.Create(nil);
  Query.Connection:=Conn;
end;

procedure TSqlStatment.SetSQL(sql: String);
begin
  // 设置 SQL 语句，可以包含参数
  sSql:=sql;
  try
    Query.Close;
    Query.SQL.Clear;
    Query.SQL.Text := sSql;
    Query.Prepare;
  except
     on E: EDatabaseError do
       MessageDlg('提示', 'DB ERROR: '+sSql+chr(13)+chr(10)+E.ClassName+chr(13)+chr(10)+E.Message, mtInformation, [mbOk], '');
     on E: Exception do
       MessageDlg('提示', 'ERROR: '+sSql+chr(13)+chr(10)+E.ClassName+chr(13)+chr(10)+E.Message, mtInformation, [mbOk], '');
  end;
end;

procedure TSqlStatment.Execute;
begin
  // 执行 SQL 语句，适合除 SELECT 语句之外的所有语句
  try
    Query.ExecSQL;
  except
     on E: EDatabaseError do
       MessageDlg('提示', 'DB ERROR: '+sSql+chr(13)+chr(10)+E.ClassName+chr(13)+chr(10)+E.Message, mtInformation, [mbOk], '');
     on E: Exception do
       MessageDlg('提示', 'ERROR: '+sSql+chr(13)+chr(10)+E.ClassName+chr(13)+chr(10)+E.Message, mtInformation, [mbOk], '');
  end;
end;

procedure TSqlStatment.Open;
begin
  // 执行 SQL 查询，即 Select 语句
  try
    Query.Open;
  except
     on E: EDatabaseError do
       MessageDlg('提示', 'DB ERROR: '+sSql+chr(13)+chr(10)+E.ClassName+chr(13)+chr(10)+E.Message, mtInformation, [mbOk], '');
     on E: Exception do
       MessageDlg('提示', 'ERROR: '+sSql+chr(13)+chr(10)+E.ClassName+chr(13)+chr(10)+E.Message, mtInformation, [mbOk], '');
  end;
end;

Destructor TSqlStatment.Free;
begin
  Query.Destroy;
end;

end.

通过一段更改用户密码的操作，来看一下通过 TSqlStatment 实例执行 SQL 语句的调用，代码如下：

procedure TPasswordForm.OkButtonClick(Sender: TObject);
var
  SqlStatment: TSqlStatment;
  Salt, SavedPassword, HashPassword: String;
begin
  // 检查密码的输入情况
  if Length(OldEdit.Text) <= 0 then
  begin
    MessageDlg('提示', '请输入旧密码!', mtInformation, [mbOk], '');
    Exit;
  end;

  if Length(NewEdit.Text) <= 0 then
  begin
    MessageDlg('提示', '请输入新密码!', mtInformation, [mbOk], '');
    Exit;
  end;

  if Length(OkEdit.Text) <= 0 then
  begin
    MessageDlg('提示', '请输入确认密码!', mtInformation, [mbOk], '');
    Exit;
  end;
  // 检查旧密码是否正确
  SqlStatment:=TSqlStatment.Create(DBDataModule.DBConnection);
  SqlStatment.SetSQL('select pwd, salt from c_usrs where usr_id = :USR_ID');
  SqlStatment.Query.Params.ParamByName('USR_ID').AsString:=CurrentUser.usr_id;
  SqlStatment.Open;

  if SqlStatment.Query.RecordCount <= 0 then
  begin
    MessageDlg('提示', '找不到用户，无法修改密码!', mtInformation, [mbOk], '');
    SqlStatment.Free;
    Exit;
  end;

  SqlStatment.Query.First;
  Salt:=SqlStatment.Query.FieldByName('salt').AsString;
  SavedPassword:=SqlStatment.Query.FieldByName('pwd').AsString;

  HashPassword := MD5Print(MD5String(Salt+OldEdit.Text));
  if HashPassword <> SavedPassword then
  begin
    MessageDlg('提示', '旧密码不正确, 请重新设置!', mtInformation, [mbOk], '');
    SqlStatment.Free;
    Exit;
  end;
  // 检查新密码与确认密码是否相同，如不相同则提示
  if NewEdit.Text <> OkEdit.Text then
  begin
    MessageDlg('提示', '新密码与确认密码不符, 请重新设置!', mtInformation, [mbOk], '');
    Exit;
  end;
  // 检查新密码与旧密码是否相同，如相同则没有必要去修改
  if OldEdit.Text = NewEdit.Text then
  begin
    MessageDlg('提示', '新密码与旧密码相同, 没有必要修改!', mtInformation, [mbOk], '');
    Exit;
  end;
  // 产生新的 SALT
  Salt:=GenGUID;
  // 计算新密码的 MD5 值
  HashPassword := MD5Print(MD5String(Salt+NewEdit.Text));
  // 更改密码
  SqlStatment.SetSQL('update c_usrs set pwd=:PWD, salt=:SALT where usr_id = :USR_ID');
  SqlStatment.Query.Params.ParamByName('PWD').AsString:=HashPassword;
  SqlStatment.Query.Params.ParamByName('SALT').AsString:=Salt;
  SqlStatment.Query.Params.ParamByName('USR_ID').AsString:=CurrentUser.usr_id;

  SqlStatment.Execute;
  SqlStatment.Free;

  MessageDlg('提示', '密码已更新!', mtInformation, [mbOk], '');

  ModalResult:=mrOk;
end;