在datasnap 中使用unidac 訪問資料(伺服器端)
阿新 • • 發佈:2018-12-06
從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 服務
剩下就是客戶端的編寫了,我們放到下一篇。
先來個客戶端效果照。