從delphi 6 開始，datasnap 作為delphi 自帶的多層框架，一直更新到最新的delphi 10.3 。同時逐步增加了很多新的功能

，比如支援REST 呼叫，支援 IIS ,apache 等伺服器。今天簡單介紹一下如何在datasnap 中使用unidac 訪問資料庫。

首先，按照嚮導生成一個標準的datasnap 伺服器。

、

點完成就自動生成對應的工程檔案

其中

• DSServer — 用來控制資料c傳輸和服務類;
• DSServerClass — 用來定義可供客戶端呼叫的伺服器類方法;
• DSHTTPService — 用來使用HTTP 協議訪問伺服器;
• DSAuthenticationManager —控制呼叫伺服器方法的使用者認證及授權;
• DSTCPServerTransport — 用來使用TCP/IP訪問伺服器。

我們可以通過程式碼做一些對應的設定

主介面程式碼：

procedure Tmainf.btStartClick(Sender: TObject);
begin
 if not ServerContainer1.DSServer1.Started then
  begin
    ServerContainer1.DSTCPServerTransport1.Port :
 
= StrToInt(edTCPIPPort.Text);
    ServerContainer1.DSHTTPService1.DSPort      := StrToInt(edHTTPPort.Text);
    ServerContainer1.DSServer1.Start;
    mStatus.Lines.Add( Formatdatetime('yyyy-mm-dd hh:nn:ss',now) + 'TCP/IP 啟動偵聽');
    ServerContainer1.DSHTTPService1.Start;
    mStatus.Lines.Add(Formatdatetime(
 
'yyyy-mm-dd hh:nn:ss',now) +'HTTP 啟動偵聽');
    btStart.Caption := '停止';
  end
  else
  begin
    ServerContainer1.DSHTTPService1.Stop;
    mStatus.Lines.Add(Formatdatetime('yyyy-mm-dd hh:nn:ss',now) + 'TCP/IP 停止偵聽');
    ServerContainer1.DSServer1.Stop;
    mStatus.Lines.Add(Formatdatetime('yyyy-mm-dd hh:nn:ss',now) +'HTTP 停止偵聽');
    btStart.Caption := '啟動';
  end;
end;

procedure TServerContainer1.DSServer1Connect(
  DSConnectEventObject: TDSConnectEventObject);
var
  ci: TDBXClientInfo;
begin
  ci := DSConnectEventObject.ChannelInfo.ClientInfo;
  mainf.mStatus.Lines.Add(Format('客戶端以 %s 方式連線 IP: %s, 埠: %s', [ci.Protocol, ci.IpAddress, ci.ClientPort]));

end;

procedure TServerContainer1.DSServer1Disconnect(
  DSConnectEventObject: TDSConnectEventObject);

var
  ci: TDBXClientInfo;
begin
  ci := DSConnectEventObject.ChannelInfo.ClientInfo;
  mainf.mStatus.Lines.Add(Format('客戶端以 %s 方式斷開 IP: %s, Port: %s', [ci.Protocol, ci.IpAddress, ci.ClientPort]));
end;

以上datasnap 伺服器端基本上就設定好了，現在我們要增加資料庫訪問功能。資料庫訪問控制元件毫無疑問，使用unidac.

本次還是以postgresql 為例。

啟動postgresql 伺服器

（這個伺服器在哪裡下載？請猛戳 www.haosql.com）.

 執行資料庫指令碼

CREATE TABLE dept
(
  deptno serial NOT NULL,
  dname character varying(14),
  loc character varying(13),
  cnt integer,
  CONSTRAINT "PK_MASTER" PRIMARY KEY (deptno)
);
 
CREATE TABLE emp
(
  empno serial NOT NULL,
  ename character varying(10),
  job character varying(9),
  mgr integer,
  hiredate timestamp without time zone,
  sal real,
  comm real,
  deptno integer NOT NULL,
  CONSTRAINT "PK_DETAIL" PRIMARY KEY (deptno, empno)
);
 
CREATE TABLE users
(
  id numeric NOT NULL,
  username character(20) NOT NULL,
  passwd character(20) NOT NULL,
  CONSTRAINT pk_users_id PRIMARY KEY (id),
  CONSTRAINT uq_users_name UNIQUE (username)
);
 
CREATE OR REPLACE FUNCTION sp_check_user(a_username character DEFAULT ''::bpchar, a_passwd character DEFAULT ''::bpchar)
  RETURNS boolean AS
$BODY$BEGIN
IF EXISTS (SELECT 1 FROM users WHERE username = a_username AND passwd = a_passwd) THEN
RETURN True;
ELSE
RETURN False;
END IF;
END;
$BODY$
  LANGUAGE plpgsql;
 
CREATE OR REPLACE FUNCTION sp_dept_modify(a_deptno numeric DEFAULT (-1), a_dname character DEFAULT ''::bpchar, a_loc character DEFAULT ''::bpchar, a_op_type numeric DEFAULT 0)
  RETURNS void AS
$BODY$begin
  case a_op_type
    when 0 then delete from dept where deptno = a_deptno;
    when 1 then insert into dept (deptno, dname, loc) values (a_deptno, a_dname, a_loc);
    else update dept set dname = a_dname, loc = a_loc where deptno = a_deptno;
  end case;
end;$BODY$
  LANGUAGE plpgsql;
 
CREATE OR REPLACE FUNCTION sp_emp_modify(a_empno numeric DEFAULT (-1), a_ename character DEFAULT ''::bpchar, a_job character DEFAULT ''::bpchar, a_mgr numeric DEFAULT 0, a_hiredate timestamp without time zone DEFAULT (now())::timestamp without time zone, a_sal numeric DEFAULT 0, a_comm numeric DEFAULT 0, a_deptno numeric DEFAULT (-1), a_op_type numeric DEFAULT 0)
  RETURNS void AS
$BODY$begin
  case a_op_type
    when 0 then delete from emp where empno = a_empno;
    when 1 then insert into emp (empno, ename, job, mgr, hiredate, sal, comm, deptno) values (a_empno, a_ename, a_job, a_mgr, a_hiredate, a_sal, a_comm, a_deptno);
    else update emp set ename = a_ename, job = a_job, mgr = a_mgr, hiredate = a_hiredate, sal = a_sal, comm = a_comm where empno = a_empno;
  end case;
end;$BODY$
  LANGUAGE plpgsql;

在ServerMethodsUnit1 裡面放置對應的控制元件。

設定資料庫連線

 設定對應的sql 引數

新增對應的 伺服器端程式碼

 function GetDept: TDataSet;
    function GetEmp(DeptNo: integer = -1): TDataSet;
    function CheckUser(username: string = ''; passwd: string = ''):boolean;
    procedure DeptModify(DeptNo: integer = -1; DName: string = ''; Loc: string = ''; op_type: integer = 0);
    procedure EmpModify(Empno: integer = -1;
                        EName: string = '';
                        Job: string = '';
                        Mgr: integer = 0;
                        HireDate: TDateTime = 0;
                        Sal: double = 0;
                        Comm: double = 0;
                        Deptno:integer = -1;
                        op_type: integer = 0);

如圖

 伺服器端就OK 了。

執行起來。

 在瀏覽器裡面我們也可以直接訪問它的REST 服務

 剩下就是客戶端的編寫了，我們放到下一篇。

先來個客戶端效果照。