中間件解析FDMEMTABLE.delta生成SQL的方法

遍歷Delta.DataView.Rows，Delta.DataView.Rows是記錄的行集，由行組成

 TFDDatSRow，即是一行記錄的對象

TFDDatSRow的方法：

 GetData（），SetData（）獲取一行一列的數值或設置一行一列的數值 

 fdmemtable.delta直接提交給中間件， 中間件可以解析fdmemtable.delta生成 INSERT OR UPDATE SQL 

{
 引用 System.JSON;

  函數名稱：DBToJSON（TFDMemTable 數據轉成SQL腳本更新）

  參數：
  DB：TFDMemTable數據集
  sTable：更新表名
  sKey:關鍵字段，寫法：ID,Name 以逗號區分
  sNoField:不需要修改或增加的字段： 寫法：ID,Sex  以逗號區分
}
function DBToJSON(DB:TFDMemTable;sTable:string;sKey:String;sNoField:String):String;
Var
  ItemKey,ItemNoField:TStringlist;
  JA:TJSONArray;
  sField,sValue,sSQL,sTmp,sName:string;
  i,j:Integer;
begin
  JA:=TJSONArray.Create;
  ItemKey:=TStringlist.Create;
  ItemNoField:=TStringlist.Create;

  ItemKey.Delimiter:=',';
  ItemKey.DelimitedText:=sKey;

  ItemNoField.Delimiter:=',';
  ItemNoField.DelimitedText:=sNoField;

  sField:='';
  sValue:='';
  sSQL:='';
  with DB.Delta.DataView.Rows do begin
    for I := 0 to Count-1 do  begin

      //判斷數據的操作狀態 :插入
      if ItemsI[i].RowState=TFDDatSRowState.rsInserted then begin

        //循環對應的數據字段
        for j := 0 to DB.Fields.Count-1 do begin
          //獲取字段名稱
          sName:=DB.Fields[J].FieldName;

          //排除不需要插入的字段信息
          if ItemNoField.IndexOf(sName)>-1 then
            Continue;

          //判斷字段的數據類型
          case DB.Fields[J].DataType of
            ftString,ftWideString,ftMemo: sTmp:=VarToStr(ItemsI[i].GetValues(sName)).QuotedString;
            ftSmallint, ftInteger,ftFloat, ftCurrency, ftBCD: sTmp:=VarToStr(ItemsI[i].GetValues(sName));
            ftDateTime: begin
              sTmp:=VarToStr(ItemsI[i].GetValues(sName));
              //日期如何沒有填寫默認為Null
              if sTmp='' then
                sTmp:='Null'
              else
                sTmp:=FormatDateTime('yyyy-mm-dd hh:ss:mm',StrToDateTime(sTmp)).QuotedString;
            end;
            ftBoolean: begin
              if ItemsI[i].GetValues(sName)=True then
                sTmp:='1'
              else
                sTmp:='0';
            end;
            else
             sTmp:=VarToStr(ItemsI[i].GetValues(sName)).QuotedString;
          end;

          //累積字段和插入值
          sField:=sField+sName+',';
          sValue:=sValue+sTmp+',';
        end;
        //拼接成SQL並插入到數組中
        JA.Add('Insert Into '+sTable+' ('+Copy(sField,1,Length(sField)-1)+')'+#13#10
          +' Values('+Copy(sValue,1,Length(sValue)-1)+')'+#13#10 ) ;

      end
      //判斷數據的操作狀態 :修改
      else if ItemsI[i].RowState in [TFDDatSRowState.rsModified,
        TFDDatSRowState.rsEditing] then begin

        for j := 0 to DB.Fields.Count-1 do begin
          sName:=DB.Fields[J].FieldName;

          //排除不需要插入的字段信息
          if ItemNoField.IndexOf(sName)>-1 then
            Continue;

          //判斷字段的數據類型
          case DB.Fields[J].DataType of
            ftString,ftWideString,ftMemo: sTmp:=VarToStr(ItemsI[i].GetValues(sName)).QuotedString;
            ftSmallint, ftInteger,ftFloat, ftCurrency, ftBCD: sTmp:=VarToStr(ItemsI[i].GetValues(sName));
            ftDateTime: begin
              sTmp:=VarToStr(ItemsI[i].GetValues(sName));
              if sTmp='' then
                sTmp:='Null'
              else
                sTmp:=FormatDateTime('yyyy-mm-dd hh:ss:mm',StrToDateTime(sTmp)).QuotedString;
            end;
            ftBoolean: begin
              if ItemsI[i].GetValues(sName)=True then
                sTmp:='1'
              else
                sTmp:='0';
            end;
            else
             sTmp:=VarToStr(ItemsI[i].GetValues(sName)).QuotedString;
          end;
          //累積更新字段值
          sField:=sField+sName+'='+sTmp+',';

          //修改數據關鍵字段，條件值
          if ItemKey.IndexOf(sName)>-1 then
            sSQL:=sSQL+' And '+ sName+' = '+VarToStr(ItemsI[i].GetData(sName,rvOriginal));

        end;
        //拼接成SQL並插入到數組中
        JA.Add('Update '+sTable+' Set '+Copy(sField,1,Length(sField)-1)+' Where '+Copy(sSQL,5,Length(sSQL)) );
      end
      else if ItemsI[i].RowState in [TFDDatSRowState.rsDeleted] then begin
        sSQL:='';
        //刪除數據關鍵字段，條件值
        for J := 0 to ItemKey.Count-1 do begin
          sValue:=ItemsI[i].GetValues(ItemKey.Strings[j]);
          if sValue.Trim<>'' then
            sSQL:=sSQL+' And '+ ItemKey.Strings[j]+' = '+QuotedStr(sValue.Trim);
        end;

        //拼接成SQL並插入到數組中
        if sSQL<>'' then
          JA.Add('Delete '+sTable+' Where '+Copy(sSQL,5,Length(sSQL)) );
      end;
    end;
  end;
  Result:=JA.ToString;
  FreeAndNil(JA);
  FreeAndNil(ItemKey);
  FreeAndNil(ItemNoField);

end;