-#include <math.h>
-#include <float.h>
-#include <string.h>
-#include <stdio.h>
-#include <errno.h>
-
-
-#include "libpq-fe.h"
-
-// some type def'n -- hopefully they are the same on your machine!
-
-typedef signed int int32; /* == 32 bits */
-typedef unsigned int uint32; /* == 32 bits */
-typedef char bool;
-
-#define TRUE 1
-#define FALSE 0
-
+#include "wkbtest.h"
/* example set-up
-create table tt (interesting bool,comments varchar(100), the_geom geometry);
-insert into tt values ( false, 'simple point', 'POINT( 10 10)' );
-insert into tt values ( false, 'simple line' , 'LINESTRING(0 0, 10 0, 10 10, 0 10, 0 0)');
-insert into tt values( true, 'polygon w/ hole','POLYGON( (0 0, 10 0, 10 10, 0 10, 0 0), (5 5, 7 5, 7 7 , 5 7 , 5 5))');
+create table wkbreader_test (interesting bool,comments varchar(100), the_geom geometry);
+insert into wkbreader_test values ( false, 'simple point', 'POINT( 10 10)' );
+insert into wkbreader_test values ( false, 'simple line' , 'LINESTRING(0 0, 10 0, 10 10, 0 10, 0 0)');
+insert into wkbreader_test values( true, 'polygon w/ hole','POLYGON( (0 0, 10 0, 10 10, 0 10, 0 0), (5 5, 7 5, 7 7 , 5 7 , 5 5))');
-dont forget to set the port, dbname, host, and user (below) so the postgres connection will work
+dont forget to set the port, dbname, host, and user in the
+environment so the postgres connection will work
Also, change the "declare cursor" command so it returns the columns you want, and converts the geometry
into wkb.
*/
-
-// This is modified from the postgres documentation for client programs (example programs)
-
-void decode_wkb(char *wkb, int *size);
-
-
-//we need to know the endian of the client machine. This is
-// taken from postgres's os.h file
-
-#if defined(__i386) && !defined(__i386__)
-#define __i386__
-#endif
-
-#if defined(__sparc) && !defined(__sparc__)
-#define __sparc__
-#endif
-
-#ifndef BIG_ENDIAN
-#define BIG_ENDIAN 4321
-#endif
-#ifndef LITTLE_ENDIAN
-#define LITTLE_ENDIAN 1234
-#endif
-
-
-#ifndef BYTE_ORDER
-#ifdef __sparc__
-#define BYTE_ORDER BIG_ENDIAN
-#endif
-#ifdef __i386__
-#define BYTE_ORDER LITTLE_ENDIAN
-#endif
-#endif
-
-
-
-//really messy debugging function for printing out wkb
-// not included inside this .c because its a messy pile of doggy-do
-//
-// it does assume "BYTE_ORDER" and "LITTLE_ENDIAN" are defined in the same
-// way as in postgres.h
-#include "printwkb.inc"
-
-
-
void
exit_nicely(PGconn *conn)
{
exit_nicely(conn);
}
- dbresult = PQexec(conn, "select OID from pg_type where typname = 'wkb';");
+ dbresult = PQexec(conn, "select OID from pg_type where typname = 'bytea';");
if (PQresultStatus(dbresult) != PGRES_TUPLES_OK)
{
double *double_val;
char *char_val;
char *wkb_val;
- char *table_name = "t";
+ char *table_name = "wkbreader_test";
char query_str[1000];
- /*
- * begin, by setting the parameters for a backend connection if the
- * parameters are null, then the system will try to use reasonable
- * defaults by looking up environment variables or, failing that,
- * using hardwired constants
- */
-
-
- pghost = "192.168.50.3";
- pgport = "5555";
- pgoptions = "user=postgres";
- pgtty = NULL;
- dbName = "t2";
-
-
-
-
-
- sprintf(conn_string,"host=%s %s port=%s dbname=%s",pghost,pgoptions,pgport,dbName);
-
-
- /* make a connection to the database */
- conn = PQconnectdb( conn_string );
+ /* make a connection to the database */
+ conn = PQconnectdb("");
- /*
- * check to see that the backend connection was successfully made
- */
- if (PQstatus(conn) == CONNECTION_BAD)
- {
- fprintf(stderr, "Connection to database '%s' failed.\n", dbName);
- fprintf(stderr, "%s", PQerrorMessage(conn));
- exit_nicely(conn);
- }
+ /*
+ * check to see that the backend connection was successfully made
+ */
+ if (PQstatus(conn) == CONNECTION_BAD)
+ {
+ fprintf(stderr, "%s", PQerrorMessage(conn));
+ exit_nicely(conn);
+ }
- //what is the geometry type's OID #?
+ //what is the geometry type's OID #?
WKB_OID = find_WKB_typeid(conn);
- /* start a transaction block */
- res = PQexec(conn, "BEGIN");
- if (!res || PQresultStatus(res) != PGRES_COMMAND_OK)
- {
- fprintf(stderr, "BEGIN command failed\n");
- PQclear(res);
- exit_nicely(conn);
- }
+ /* start a transaction block */
+ res = PQexec(conn, "BEGIN");
+ if (!res || PQresultStatus(res) != PGRES_COMMAND_OK)
+ {
+ fprintf(stderr, "%s", PQerrorMessage(conn));
+ PQclear(res);
+ exit_nicely(conn);
+ }
- /*
- * should PQclear PGresult whenever it is no longer needed to avoid
- * memory leaks
- */
- PQclear(res);
+ /*
+ * should PQclear PGresult whenever it is no longer needed to avoid
+ * memory leaks
+ */
+ PQclear(res);
- /*
- * fetch rows from the pg_database, the system catalog of
- * databases
- */
- sprintf(query_str, "DECLARE mycursor BINARY CURSOR FOR select text(num), asbinary(the_geom,'ndr') as wkb from %s",table_name);
+ /*
+ * fetch rows from the pg_database, the system catalog of
+ * databases
+ */
+ sprintf(query_str, "DECLARE mycursor BINARY CURSOR FOR select text(num), asbinary(the_geom,'ndr') as wkb from %s", table_name);
printf(query_str); printf("\n");
- res = PQexec(conn, query_str);
+ res = PQexec(conn, query_str);
- if (!res || PQresultStatus(res) != PGRES_COMMAND_OK)
- {
- fprintf(stderr, "DECLARE CURSOR command failed\n");
- PQclear(res);
- exit_nicely(conn);
- }
- PQclear(res);
+ if (!res || PQresultStatus(res) != PGRES_COMMAND_OK)
+ {
+ fprintf(stderr, "DECLARE CURSOR command failed\n");
+ fprintf(stderr, "%s", PQerrorMessage(conn));
+ PQclear(res);
+ exit_nicely(conn);
+ }
+ PQclear(res);
- res = PQexec(conn, "FETCH ALL in mycursor");
- if (!res || PQresultStatus(res) != PGRES_TUPLES_OK)
- {
- fprintf(stderr, "FETCH ALL command didn't return tuples properly\n");
- PQclear(res);
- exit_nicely(conn);
- }
+ res = PQexec(conn, "FETCH ALL in mycursor");
+ if (!res || PQresultStatus(res) != PGRES_TUPLES_OK)
+ {
+ fprintf(stderr, "FETCH ALL command didn't return tuples properly\n");
+ fprintf(stderr, "%s", PQerrorMessage(conn));
+ PQclear(res);
+ exit_nicely(conn);
+ }
for (row=0; row< PQntuples(res); row++)
{
else
printf("%s: FALSE\n",field_name);
}
- if (field_type ==23 )//int4 (int)
+ else if (field_type ==23 )//int4 (int)
{
int_val = (int *) PQgetvalue(res, row, field);
printf("%s: %i\n",field_name,*int_val);
}
- if (field_type ==700 )//float4 (float)
+ else if (field_type ==700 )//float4 (float)
{
float_val = (float *) PQgetvalue(res, row, field);
printf("%s: %g\n",field_name,*float_val);
}
- if (field_type ==701 )//float8 (double)
+ else if (field_type ==701 )//float8 (double)
{
double_val = (double *) PQgetvalue(res, row, field);
printf("%s: %g\n",field_name,*double_val);
}
- if ( (field_type ==1043 ) || (field_type==25) )//varchar
+ else if ( (field_type ==1043 ) || (field_type==25) )//varchar
{
char_val = (char *) PQgetvalue(res, row, field);
printf("%s: %s\n",field_name,char_val);
}
- if (field_type ==WKB_OID ) //wkb
+ else if (field_type == WKB_OID ) //wkb
{
char_val = (char *) PQgetvalue(res, row, field);
printf("%s: ", field_name);
- decode_wkb(char_val, &junk);
+ // skip 4 bytes varlena size
+ decode_wkb(char_val, &junk);
+ printf("\n");
}
}
projects / postgis / commitdiff