public static Datatypes getDataType()

in streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java [173:200]

• 26 lines of code
• 15 McCabe index (conditional complexity)

  public static Datatypes getDataType(DbDataTypes dbDataType) throws SpRuntimeException {

    switch (dbDataType) {
      case BOOLEAN:
        return Datatypes.Boolean;
      case TEXT:
      case VAR_CHAR:
      case TIMESTAMP:
      case DATE:
      case TIME:
        return Datatypes.String;
      case DOUBLE_PRECISION:
        return Datatypes.Double;
      case FLOAT:
      case REAL:
      case DATETIME:
        return Datatypes.Float;
      case BIGINT:
      case TINYINT:
        return Datatypes.Long;
      case INT:
      case INTEGER:
        return Datatypes.Integer;
      default:
        throw new SpRuntimeException("Unknown SQL datatype");
    }

  }