public String generateSqlString()

in backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/sink/OutSqlFileSink.java [142:171]

30 lines of code
3 McCabe index (conditional complexity)


  public String generateSqlString(TimeSeriesRowModel timeSeriesRowModel) {
    DeviceModel deviceModel = timeSeriesRowModel.getDeviceModel();
    StringBuilder sql = new StringBuilder();
    StringBuilder timeseries = new StringBuilder();
    StringBuilder values = new StringBuilder();
    sql.append(" insert into ").append(deviceModel.getDeviceName());
    timeseries.append("(time");
    values.append(" values (").append(timeSeriesRowModel.getTimestamp());
    timeSeriesRowModel
        .getIFieldList()
        .forEach(
            column -> {
              if (column.getField() != null) {
                timeseries
                    .append(",")
                    .append(column.getColumnName().replace(deviceModel.getDeviceName() + ".", ""));
                values
                    .append(",")
                    .append(column.getField().getObjectValue(column.getField().getDataType()));
              }
            });
    timeseries.append(") ");
    values.append(");");
    sql.append(timeseries);
    if (deviceModel.isAligned()) {
      sql.append(" aligned ");
    }
    sql.append(values).append("\r\n");
    return sql.toString();
  }