com.mapd.utility.db_vendors.PostGis_types Class Reference

Inheritance diagram for com.mapd.utility.db_vendors.PostGis_types:

Collaboration diagram for com.mapd.utility.db_vendors.PostGis_types:

Public Member Functions
String	get_wkt (ResultSet rs, int column_number, String gis_type_name) throws SQLException
String	find_gis_type (Connection conn, ResultSetMetaData metadata, int column_number) throws SQLException

Protected Member Functions
	PostGis_types ()
Protected Member Functions inherited from com.mapd.utility.db_vendors.Db_vendor_types
	Db_vendor_types ()

Private Member Functions
String	wkt_point (PGpoint point)
String	find_type_detail (Connection conn, String ref_table_name, String ref_column_name, String column_name) throws SQLException

Static Private Attributes
static Hashtable< String, String >	extra_types

Additional Inherited Members
Static Public Member Functions inherited from com.mapd.utility.db_vendors.Db_vendor_types
static com.mapd.utility.db_vendors.Db_vendor_types	Db_vendor_factory (String connection_str)
Static Protected Attributes inherited from com.mapd.utility.db_vendors.Db_vendor_types
static HashSet< Integer >	valid_srid

Detailed Description

Definition at line 83 of file Db_vendor_types.java.

Constructor & Destructor Documentation

com.mapd.utility.db_vendors.PostGis_types.PostGis_types ( )

inlineprotected

Definition at line 84 of file Db_vendor_types.java.

{}

Member Function Documentation

String com.mapd.utility.db_vendors.PostGis_types.find_gis_type ( Connection  conn, ResultSetMetaData  metadata, int  column_number  ) throws SQLException

inlinevirtual

Implements com.mapd.utility.db_vendors.Db_vendor_types.

Definition at line 139 of file Db_vendor_types.java.

References com.mapd.utility.db_vendors.PostGis_types.extra_types, com.mapd.utility.db_vendors.PostGis_types.find_type_detail(), and Experimental.String.

                              {
    String column_name = metadata.getColumnName(column_number);
    String column_type_name = metadata.getColumnTypeName(column_number);
    if (column_type_name.equalsIgnoreCase("geography"))
      return find_type_detail(
              conn, "geography_columns", "f_geography_column", column_name);
    else if (column_type_name.equalsIgnoreCase("geometry"))
      return find_type_detail(conn, "geometry_columns", "f_geometry_column", column_name);
    if (!extra_types.containsKey(column_type_name))
      throw new SQLException(
              "type not supported: " + column_type_name + " for column " + column_name);
    return extra_types.get(column_type_name);
  }

Here is the call graph for this function:

String com.mapd.utility.db_vendors.PostGis_types.find_type_detail ( Connection  conn, String  ref_table_name, String  ref_column_name, String  column_name  ) throws SQLException

inlineprivate

Definition at line 155 of file Db_vendor_types.java.

References com.mapd.utility.db_vendors.PostGis_types.extra_types, Integer, Experimental.String, run_benchmark_import.type, and com.mapd.utility.db_vendors.Db_vendor_types.valid_srid.

Referenced by com.mapd.utility.db_vendors.PostGis_types.find_gis_type().

                                                  {
    String omnisci_type = null;
    Statement detail_st = conn.createStatement();
    // Select for a specific column name from the ref table.
    String select = "select type, srid from " + ref_table_name + "  where "
            + ref_column_name + " = '" + column_name + "'";
    ResultSet rs = detail_st.executeQuery(select);
    String ps_column_type = null;
    int ps_srid = 0;
    // The select statment above, can return multiple values qualified by schema/table.
    // Unfortunately at this stage only the original postgres column name is known.  If
    // get mulitple returns with the same column name, but different types we will not be
    // able to separate which specific column is which type.  This loop checks for this
    // condition and thows when detected.
    while (rs.next()) {
      String type = rs.getString(1);
      int srid = rs.getInt(2);
      // If multiple rows are returned with different geo types for a single coulmn name
      // then throw.
      if (ps_column_type != null
              && (ps_column_type.equalsIgnoreCase(type) || srid != ps_srid)) {
        throw new SQLException("multiple column definitions [" + ps_column_type + ":"
                + type + "] found for column_name [" + column_name + "]");
      }
      ps_column_type = type;
      ps_srid = srid;
    }
    if (!extra_types.containsKey(ps_column_type.toLowerCase()))
      throw new SQLException("type not supported");
    omnisci_type = extra_types.get(ps_column_type.toLowerCase());
    if (ps_srid != 0) {
      if (!valid_srid.contains(new Integer(ps_srid)))
        throw new SQLException("type not supported");
      omnisci_type = omnisci_type + "," + ps_srid;
    }
    return new String("geometry(" + omnisci_type + ")");
  }

Here is the caller graph for this function:

String com.mapd.utility.db_vendors.PostGis_types.get_wkt ( ResultSet  rs, int  column_number, String  gis_type_name  ) throws SQLException

inlinevirtual

Implements com.mapd.utility.db_vendors.Db_vendor_types.

Definition at line 100 of file Db_vendor_types.java.

References Fragmenter_Namespace.indexOf(), and com.mapd.utility.db_vendors.PostGis_types.wkt_point().

                              {
    if (gis_type_name.equalsIgnoreCase("geometry")
            || gis_type_name.equalsIgnoreCase("geography")) {
      Object gis_object = rs.getObject(column_number);
      PGgeometry pGeometry = (PGgeometry) gis_object;
      if (pGeometry == null) throw new SQLException("unknown type");
      // Try and trim the front SRID=nnnn; value from the string  returned from the db.
      // If there isn't a SRID=nnnn; string (marked by the ';') then simply
      // return the whole string
      int semi_colon_indx = pGeometry.getValue().indexOf(';');
      if (-1 != semi_colon_indx && semi_colon_indx < pGeometry.getValue().length()) {
        return pGeometry.getValue().substring(semi_colon_indx + 1);
      }
      return pGeometry.getValue();
    }
    StringBuffer WKT_string = new StringBuffer();
    if (gis_type_name.equalsIgnoreCase("point")) {
      PGpoint point = (PGpoint) rs.getObject(column_number);
      WKT_string.append(extra_types.get(gis_type_name) + "(" + wkt_point(point) + ")");

    } else if (gis_type_name.equalsIgnoreCase("polygon")) {
      PGpolygon polygon = (PGpolygon) rs.getObject(column_number);
      WKT_string.append(extra_types.get(gis_type_name) + "((");
      for (PGpoint p : polygon.points) {
        WKT_string.append(wkt_point(p) + ",");
      }
      WKT_string.replace(WKT_string.length() - 1, WKT_string.length(), "))");
    } else if (gis_type_name.equalsIgnoreCase("lseg")) {
      PGlseg lseg = (PGlseg) rs.getObject(column_number);
      WKT_string.append(extra_types.get(gis_type_name) + "(");
      for (PGpoint p : lseg.point) {
        WKT_string.append(wkt_point(p) + ",");
      }
      WKT_string.replace(WKT_string.length() - 1, WKT_string.length(), ")");
    }
    return WKT_string.toString();
  }

Here is the call graph for this function:

String com.mapd.utility.db_vendors.PostGis_types.wkt_point ( PGpoint  point )

inlineprivate

Definition at line 96 of file Db_vendor_types.java.

References Experimental.String.

Referenced by com.mapd.utility.db_vendors.PostGis_types.get_wkt().

                                          {
    return new String("" + point.x + " " + point.y);
  }

Here is the caller graph for this function:

Member Data Documentation

Hashtable<String, String> com.mapd.utility.db_vendors.PostGis_types.extra_types

staticprivate

Initial value:

= new Hashtable() {
    {
      put("point", "POINT");
      put("lseg", "linestring");
      put("linestring", "linestring");
      put("polygon", "polygon");
      put("multipolygon", "multipolygon");
    }
  }

Definition at line 87 of file Db_vendor_types.java.

Referenced by com.mapd.utility.db_vendors.PostGis_types.find_gis_type(), and com.mapd.utility.db_vendors.PostGis_types.find_type_detail().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/utility/src/main/java/com/mapd/utility/db_vendors/Db_vendor_types.java