umssqlmemberdao.~pas

用DELPH写的DAO访问模块.有连接池.应用了各种模块,把数据库操作

unit uMssqlMemberDAO;

interface

uses
  Classes, SysUtils, Windows, Db, uMemberDAO, ADODB;

type
  TMssqlMemberDAO = class(TInterfacedObject,IMemberDAO)
  private
    fInsert : string;
    fDelete : string;
    fUpdate : string;
    fFind : string;
    fCount : string;
    fMax : string;
    fCmd : TADOCommand;
    fQry : TADOQuery;
    fconn : TADOConnection;
  public
    constructor Create(pconn : TADOConnection);
    destructor Destroy; override;
    
    function insertMember(pMember: TMember) : integer;
    function deleteMember(pMember: TMember) : boolean;
    function updateMember(pMember: TMember) : boolean;
    function findMember(pID: integer) : TMember;

  end;

implementation

{ TMssqlMemberDAO }

constructor TMssqlMemberDAO.Create(pconn: TADOConnection);
begin
  fconn := pconn;
  fcmd := TADOCommand.Create(nil);
  fcmd.Connection := fconn;
  fQry := TADOQuery.Create(nil);
  fQry.Connection := fconn;
end;

function TMssqlMemberDAO.deleteMember(pMember: TMember): boolean;
begin
  //
end;

destructor TMssqlMemberDAO.Destroy;
begin
  fcmd.Free;
  fQry.Free;
  inherited;
end;

function TMssqlMemberDAO.findMember(pID: integer): TMember;
begin
  //
end;

function TMssqlMemberDAO.insertMember(pMember: TMember): integer;
var
  fID : integer;
begin
  {
  fInsert := 'insert into member(mbname) values(:mbname)';
  with fcmd do
  begin
    CommandText := fInsert;
    Parameters.ParamByName('mbname').Value := pMember.MemberName;
    Execute;
  end;
  }
  fFind := 'insert into member(mbname) values(:mbname);select ID from member where ID=@@IDENTITY';
  with fQry do
  begin
    Close;
    Sql.Text := fFind;
    Open;
    if not IsEmpty then
      fID := FieldByName('ID').AsInteger
    else
      fID := -1;
    Close;
  end;
  result := fID;
end;

function TMssqlMemberDAO.updateMember(pMember: TMember): boolean;
begin
  //
end;

end.