[Geotools-commits] svn - r38497 - trunk/modules/plugin/jdbc/jdbc-sqlserver/src/main/java/org/geotools/data/sqlserver

[<svn...@os...>]

Author: aaime
Date: 2012-01-17 09:13:55 -0800 (Tue, 17 Jan 2012)
New Revision: 38497

Modified:
   trunk/modules/plugin/jdbc/jdbc-sqlserver/src/main/java/org/geotools/data/sqlserver/SQLServerDialect.java
Log:
[GEOT-4020] Have SQL server store use WKB for geometry transfers

Modified: trunk/modules/plugin/jdbc/jdbc-sqlserver/src/main/java/org/geotools/data/sqlserver/SQLServerDialect.java
===================================================================
--- trunk/modules/plugin/jdbc/jdbc-sqlserver/src/main/java/org/geotools/data/sqlserver/SQLServerDialect.java	2012-01-16 18:26:12 UTC (rev 38496)
+++ trunk/modules/plugin/jdbc/jdbc-sqlserver/src/main/java/org/geotools/data/sqlserver/SQLServerDialect.java	2012-01-17 17:13:55 UTC (rev 38497)
@@ -42,6 +42,7 @@
 import com.vividsolutions.jts.geom.Geometry;
 import com.vividsolutions.jts.geom.GeometryFactory;
 import com.vividsolutions.jts.io.ParseException;
+import com.vividsolutions.jts.io.WKBReader;
 import com.vividsolutions.jts.io.WKTReader;
 
 /**
@@ -59,7 +60,7 @@
     public SQLServerDialect(JDBCDataStore dataStore) {
         super(dataStore);
     }
-
+    
     @Override
     public boolean includeTable(String schemaName, String tableName,
             Connection cx) throws SQLException {
@@ -184,17 +185,8 @@
     
     @Override
     public void encodeGeometryColumn(GeometryDescriptor gatt, String prefix, int srid, StringBuffer sql) {
-        sql.append( "CAST(");
         encodeColumnName( prefix, gatt.getLocalName(), sql );
-        sql.append( ".STSrid as VARCHAR)");
-        
-        sql.append( " + ':' + " );
-        
-        encodeColumnName( prefix, gatt.getLocalName(), sql );
-        sql.append( ".STAsText()");
-        
-        //encodeColumnName(gatt.getLocalName(), sql);
-        //sql.append( ".STAsText()");
+        sql.append( ".STAsBinary()");
     }
     
     @Override
@@ -213,8 +205,15 @@
     public Geometry decodeGeometryValue(GeometryDescriptor descriptor,
             ResultSet rs, String column, GeometryFactory factory, Connection cx)
             throws IOException, SQLException {
-        String s = rs.getString( column );
-        return decodeGeometry ( s, factory );
+       byte[] bytes = rs.getBytes(column);
+       if(bytes == null) {
+           return null;
+       }
+       try {
+           return new WKBReader(factory).read(bytes);
+       } catch ( ParseException e ) {
+           throw (IOException) new IOException().initCause( e );
+       }
     }
     
     Geometry decodeGeometry( String s, GeometryFactory factory ) throws IOException {
@@ -329,4 +328,5 @@
             sql.append(tableName);
         }
     }
+    
 }