kbmmw 与extjs 的初次结合

Posted 2020-10-11 Delphi 窑洞

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kbmmw 与extjs 的初次结合相关的知识，希望对你有一定的参考价值。

前面写了extjs 的安装，今天写一下kbmmw 与extjs 的结合，参照delphi 产品经理marco文章。

由于extjs 设计时要读取服务器端的数据，所以先要做一个rest 服务器。

先要用kbmmw 建一个web 服务器，可以参照我以前写的例子。

由于要返回数据库，因此加入对应的数据库访问控件，我使用unidac 加postgresql,需要的可以在

www.hoasql.com 去下载。

我们开始写服务器端。加上必要的数据库访问控件，并保证运行正常。

进入webservice 单元，加对应的代码。

function Twebsrv.Performget(ClientIdent:TkbmMWClientIdentity; const AURL:string; const Args:array of Variant):Variant;
var
  mystringstream:Tstringstream;
  MimeType,s,scallback:string;
  Charset,tablename:string;
  qv:TkbmMWHTTPQueryValues;
  dataurl,mysql,swhere:string;
    I: Integer;
begin

    qv:=TkbmMWHTTPQueryValues.Create;
    dataurl:=args[0];
    qv.AsString:=Args[2];
   if length(Args)<1 then
        kbmMWRaiseException(KBMMW_ERR_SERVICE_HTTP_URLMISSING,\'Missing URL.\');

  try

    if args[0]=\'/version\' then
    begin
        result:=\'kbmmw 5.03\';
        exit;
    end;


    if args[0]=\'/getdata\' then

        begin


          tablename:=qv.ValueByName[\'tname\'] ;

          if tablename=\'\' then
            begin

                  result:=\'表名不能为空!\';
                  exit;
            end;

          swhere:= qv.ValueByName[\'where\'];    //where 需要编码。注意注入

          if swhere<>\'\' then
            begin
                if pos(\';\',swhere)>0 then
                  begin
                      result:=\'非法条件!\';
                      exit;
                  end;
             swhere:=\' where \'+swhere;
            end;


             mysql:=\'select *  from \'+tablename;

             mysql:=mysql+swhere;


             s:=datatojson(tablename, mysql,\'\',\'\');

             scallback:=qv.ValueByName[\'callback\'];
             if scallback<>\'\'  then
                result:=scallback+\'(\'+s+\')\'
              else
                Result:=s;
             exit;


         end;

      result:=inherited Performget(ClientIdent,aurl,Args) ;
   finally
        qv.Free;
        mystringstream.Free;

   end;
end;

下面是数据库转json 的代码

function Twebsrv.datatojson(tname,datasql, startp, endp: string;
  inparams: tstringlist = nil): string;
var
   sjosn:TkbmMWJSONStreamer;
  alljson: TkbmMWJSONObject;
  datajson: TkbmMWJSONArray;
  recordjson: TkbmMWJSONObject;
   starti, endi, i: integer;
  idate:int64;
  mydate:Tdatetime;
begin

    if startp = \'\' then
    starti := 0
  else
    starti := strtoint(startp);

  alljson := TkbmMWJSONObject.Create;// ( (stobject);

  sjosn:=TkbmMWJSONStreamer.Create;
  try
    with cx do
    begin
      sql.clear;
      sql.add(datasql);

      if inparams <> nil then
      begin
        for i := 0 to inparams.Count - 1 do
        begin
          if inparams.Names[i] <> \'\' then
          begin
            cx.Parambyname[inparams.Names[i]].AsString :=
              inparams.ValueFromIndex[i];
          end;
        end;
      end;
        try
              Open;
         except
              result:=\'数据库打开错误!2\';
               exit;

          end;
      datajson :=TkbmMWJSONArray.Create;//(starray);
     while not eof do
      begin
        recordjson :=TkbmMWJSONObject.Create;

            for i := 0 to fields.Count - 1 do
            begin
              case fields[i].DataType of
                 ftDate, ftTime, ftDateTime:
                     begin
                        mydate:=fields[i].AsDateTime;

                      recordjson.AsString[fields[i].FieldName]:=formatdatetime(\'yyyy-mm-dd hh:nn:ss\',mydate);
                     end

                 else
                        recordjson .AsString[fields[i].FieldName ]:= fields[i].AsString;

                end;
            end;
        datajson.add(recordjson);

        next;
      end;

    alljson.AsArray[tname] := datajson;
   end;
     result := sjosn.SaveToUTF16String(alljson);
  finally
     sjosn.Free;
     alljson.Free;
  end;



end;