全部产品
数据传输服务DTS

订阅数据SQL封装简介

更新时间:2017-06-07 13:26:11   分享:   

数据订阅SDK订阅到的数据为DTS自定义格式,本小节简单介绍各种类型SQL语句解析的代码实现。

DDL解析

如果一个Record 是DDL语句,那么这个Record 的操作类型为DDL。且DDL语句存储在第一列的value中。具体获取DDL语句的代码如下:

  1. String ddl_string;
  2. Record.Type type=record.getOpt();
  3. if(type.equals(Record.Type.DDL)){
  4. List<DataMessage.Record.Field> fields = record.getFieldList();
  5. ddl_string = fields.get(0).getValue().toString();
  6. }

Insert 解析

如果一个Record 是Insert语句,那么这个Record的操作类型为INSERT。具体获取Insert完整语句的代码如下:

  1. StringBuilder insert_string=new StringBuilder();
  2. Record.Type type=record.getOpt();
  3. DataMessage.Record.Field field;
  4. StringBuilder FieldName=new StringBuilder();
  5. StringBuilder FieldValue = new StringBuilder();
  6. if(type.equals(Record.Type.INSERT)){
  7. int i=0;
  8. List<DataMessage.Record.Field> fields = record.getFieldList();
  9. for (; i < fields.size(); i++) {
  10. field = fields.get(i); FieldName.append('`'+field.getFieldname().toLowerCase()+'`');
  11. FieldValue.append(field.getValue());
  12. if (i != fields.size() - 1) {
  13. FieldName.append(',');
  14. FieldValue.append(',');
  15. }
  16. }
  17. insert_string.append("insert "+ record.getTablename()+"("+FieldName.toString()+") values("+FieldValue.toString()+");");
  18. }

Update 解析

如果一个Record 是Update语句,那么这个Record的操作类型为UPDATE。

update更新前的字段存储在:Record.getFieldList()中索引为偶数的Field,更新后的字段值存储在:索引为奇数的Field。

下面的示例代码介绍当update的表有主键时,获取Insert完整语句的代码示例:

  1. StringBuilder update_string=new StringBuilder();
  2. Record.Type type=record.getOpt();
  3. DataMessage.Record.Field field;
  4. StringBuilder SetValue = new StringBuilder();
  5. StringBuilder WhereCondition = new StringBuilder();
  6. String ConditionStr;
  7. boolean hasPk=false;
  8. boolean pkMode=false;
  9. boolean hasSet=false;
  10. if(type.equals(Record.Type.UPDATE)){
  11. int i=0;
  12. DataMessage.Record.Field OldField = null;
  13. DataMessage.Record.Field NewField = null;
  14. List<DataMessage.Record.Field> fields = record.getFieldList();
  15. for (; i <fields.size() ; i++) {
  16. if (i % 2 == 0) {
  17. OldField = fields.get(i);
  18. continue;
  19. }
  20. NewField = fields.get(i);
  21. if (field.isPrimary()) {
  22. if (hasPk) {
  23. WhereCondition.append(" and ");
  24. }
  25. //where old value
  26. ConditionStr = getFieldValue(OldField);
  27. if(ConditionStr==null){ WhereCondition.append("`"+field.getFieldname().toLowerCase()+"`" + " " + "is null");
  28. }else{
  29. WhereCondition.append("`"+field.getFieldname().toLowerCase()+"`"+" = "+ NewField.getValue());
  30. }
  31. hasPk = true;
  32. }
  33. if (hasSet) {
  34. SetValue.append(COMMA);
  35. }
  36. SetValue.append("`"+field.getFieldname().toLowerCase()+"`" + " = " + field.getValue());
  37. String setStr = getFieldValue(field);
  38. hasSet = true;
  39. }
  40. update_string.append("Update "+record.getTablename() +" Set " + SetValue + " Where "+WhereCondition +";");
  41. }

Delete 解析

如果一个Record 是Delete语句,那么这个Record的操作类型为DELETE。下面的代码示例简单介绍当delete对应的表有主键时,如何获取完整的Delete语句:

  1. StringBuilder delete_string=new StringBuilder();
  2. Record.Type type=record.getOpt();
  3. DataMessage.Record.Field field;
  4. StringBuilder FieldName=new StringBuilder();
  5. StringBuilder FieldValue = new StringBuilder();
  6. StringBuilder DeleteCondition = new StringBuilder();
  7. boolean hasPk=false;
  8. boolean pkMode=false;
  9. if(type.equals(Record.Type.DELETE)){
  10. int i=0;
  11. List<DataMessage.Record.Field> fields = record.getFieldList();
  12. delete_string.append("Delete From" + record.getTablename() + "where");
  13. // 表是否有主键?
  14. if (record.getPrimaryKeys() != null) {
  15. pkMode = record.getPrimaryKeys().length() > 0 ? true : false;
  16. }
  17. for (; i < fields.size(); i++) {
  18. if ((pkMode && !field.isPrimary())) {
  19. continue;
  20. }
  21. if (hasPk) {
  22. delete_string.append(" and ");
  23. }
  24. delete_string.append(field.getFieldname() + "=" + field.getValue());
  25. hasPk = true;
  26. }
  27. delete_string.append(";");
  28. }

Replace 解析

如果源库执行了Replace语句,那么这个Record的操作类型为UPDATE或INSERT。当replace设置的值不存在时,Record的操作类型为INSERT,当replace设置的值存在时,Record的操作类型为UPDATE。

Begin 解析

如果一个Record 是Begin语句,那么这个Record的操作类型为BEGIN。begin语句没有实际内容,所以不需要对Field做处理,只需要判断操作为begin即可,具体获取代码如下:

  1. StringBuilder sql_string = new StringBuilder();
  2. Record.Type type = record.getOpt();
  3. if(type.equals(Record.Type.BEGIN)){
  4. sql_string.append("Begin");
  5. }

Commit 解析

如果一个Record 是Commit语句,那么这个Record的操作类型为COMMIT。commit语句没有实际内容,所以不需要对Field做处理,只需要判断操作为commit即可。

  1. StringBuilder sql_string = new StringBuilder();
  2. Record.Type type = record.getOpt();
  3. if(type.equals(Record.Type.COMMIT)){
  4. sql_string.append("commit");
  5. }
本文导读目录
本文导读目录
以上内容是否对您有帮助?