mormot接口封裝

mormot接口封裝

mormot基於http.sys通訊，支持海量並發，用mormot開發的服務端，長時間運行非常穩定。

經常有人說mormot晦澀難懂，但經過封裝以后的MORMOT接口，調用異常簡單。支持DELPHI7及以上版本調用哦！

procedure TForm1.DownFile(filename: string);
// 下載文件
var
  url: SockString;
  i: integer;
  serial: TynSerial;
  ms: TMemoryStream;
begin
  serial := TynSerial.Create;
  ms := TMemoryStream.Create;
  try
    url := 'downfile';
    serial.WriteString('filename', filename);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadFile('filecontent', ms);
      ms.SaveToFile('d:\' + filename);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
    ms.Free;
  end;
end;

　　

procedure TForm1.Qry(accountno, sql: string; DataSet: TFDMemTable);
// TFDMemTable查詢
var
  url: SockString;
  i: integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'query2';
    serial.WriteString('accountno', accountno);
    serial.WriteString('sql', sql);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadFDDataSet('dataset', DataSet);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

procedure TForm1.Qry(accountno, sql: string; DataSet: TClientDataSet);
// TClientDataSet查詢
var
  url: SockString;
  i: integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'query3';
    serial.WriteString('accountno', accountno);
    serial.WriteString('sql', sql);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadClientDataSet('dataset', DataSet);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

procedure TForm1.redisQry(cacheKey, accountno, sql: string; DataSet: TFDMemTable);
// redis緩存 查詢
var
  url: SockString;
  i: integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'redis';
    serial.WriteString('accountno', accountno);
    serial.WriteString('sql', sql);
    serial.WriteString('cachekey', cacheKey);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadFDDataSet('dataset', DataSet);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

procedure TForm1.Qry(middleMark, accountno, sql: string; DataSet: TFDMemTable);
// 中間件橋接查詢
var
  url: SockString;
  i: integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'bridgequery';
    serial.WriteString('accountno', accountno);
    serial.WriteString('sql', sql);
    serial.WriteString('middlemark', middleMark);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadFDDataSet('dataset', DataSet);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

procedure TForm1.Qrys(accountno, sql, sql2: string; DataSet, DataSet2: TClientDataSet);
// TClientDataSet主從表查詢
var
  url: SockString;
  i: integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'querys2';
    serial.WriteString('accountno', accountno);
    serial.WriteString('sql', sql);
    serial.WriteString('sql2', sql2);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadClientDataSet('dataset', DataSet);
      serial.ReadClientDataSet('dataset2', DataSet2);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

procedure TForm1.Qrys(accountno, sql, sql2: string; DataSet, DataSet2: TFDMemTable);
// TFDMemTable主從表查詢
var
  url: SockString;
  i: integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'querys';
    serial.WriteString('accountno', accountno);
    serial.WriteString('sql', sql);
    serial.WriteString('sql2', sql2);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadFDDataSet('dataset', DataSet);
      serial.ReadFDDataSet('dataset2', DataSet2);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

function TForm1.Save(accountno, tablename: string; dataset: TClientDataSet): string;
// clientDataSet提交
var
  url: SockString;
  i: Integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'save';
    serial.WriteString('accountno', accountno);
    serial.WriteString('tablename', tablename);
    serial.WriteDelta('delta', dataset);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      if serial.ReadBool('result') then
        dataset.MergeChangeLog;
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

function TForm1.Save(accountno, tablename: string; dataset: TFDMemTable): string;
// TFDMemTable提交
var
  url: SockString;
  i: Integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'save2';
    serial.WriteString('accountno', accountno);
    serial.WriteString('tablename', tablename);
    serial.WriteFDDelta('delta', dataset);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      if serial.ReadBool('result') then
        dataset.MergeChangeLog
      else
        ShowMessage('提交失敗');
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

procedure TForm1.StoredProc(accountno, spname, params: string; DataSet: TClientDataSet);
// 存儲過程
var
  url: SockString;
  i: Integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'spopen3';
    serial.WriteString('accountno', accountno);
    serial.WriteString('spname', spname);
    serial.WriteString('params', params);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin
      serial.Text := FHttp.Content;
      serial.ReadClientDataSet('dataset', DataSet);
    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;

　　

procedure TForm1.UpFile(filename: string);
// 上傳文件
var
  url: SockString;
  i: Integer;
  serial: TynSerial;
begin
  serial := TynSerial.Create;
  try
    url := 'upfile';
    serial.WriteFile('filecontent', filename);
    serial.WriteString('filename', filename);
    i := FHttp.Post(url, serial.Text, FDataType);
    if i = 200 then
    begin

    end
    else
      ShowMessage(i.ToString + ' error');
  finally
    serial.Free;
  end;
end;