Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/mono/mono.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
path: root/mcs/class/System.Data/Test/ReadPostgresData.cs
diff options
context:
space:
mode:
Diffstat (limited to 'mcs/class/System.Data/Test/ReadPostgresData.cs')
-rw-r--r--mcs/class/System.Data/Test/ReadPostgresData.cs585
1 files changed, 0 insertions, 585 deletions
diff --git a/mcs/class/System.Data/Test/ReadPostgresData.cs b/mcs/class/System.Data/Test/ReadPostgresData.cs
deleted file mode 100644
index c1fc05b0a19..00000000000
--- a/mcs/class/System.Data/Test/ReadPostgresData.cs
+++ /dev/null
@@ -1,585 +0,0 @@
-//
-// ReadPostgresData.cs
-//
-// Uses the PostgresLibrary to retrieve a recordset.
-// This is not meant to be used in Production, but as a
-// learning aid in coding class System.Data.SqlClient.SqlDataReader.
-//
-// Bits of code were borrowed from libgda.
-//
-// Author:
-// Daniel Morgan <danmorg@sc.rr.com>
-//
-// (C) 2002 Daniel Morgan
-//
-
-using System;
-using System.Data;
-using System.Runtime.InteropServices;
-using System.Diagnostics;
-
-namespace LearnToCreateSqlDataReader
-{
- sealed public class PostgresHelper {
-
- public static object OidTypeToSystem (int oid, string value) {
- object obj = null;
-
- Console.WriteLine("===== oid: " + oid + " value: " + value);
-
- switch(oid) {
- case 1043: // varchar
- Console.WriteLine("oid 1023 varchar ==> String found");
- obj = (object) String.Copy(value); // String
- break;
- case 25: // text
- Console.WriteLine("oid 25 text ==> String found");
- obj = (object) String.Copy(value); // String
- break;
- case 18: // char
- Console.WriteLine("oid 18 char ==> String found");
- obj = (object) String.Copy(value); // String
- break;
- case 16: // bool
- Console.WriteLine("oid 16 bool ==> Boolean found");
- obj = (object) Boolean.Parse(value);
- break;
- case 21: // int2
- Console.WriteLine("oid 21 int2 ==> Int16 found");
- obj = (object) Int16.Parse(value);
- break;
- case 23: // int4
- Console.WriteLine("oid 23 int4 ==> Int32 found");
- obj = (object) Int32.Parse(value);
- break;
- case 20: // int8
- Console.WriteLine("oid 20 int8 ==> Int64 found");
- obj = (object) Int64.Parse(value);
- break;
- default:
- Console.WriteLine("OidTypeToSystem Not Done Yet: oid: " +
- oid + " Value: " + value);
- break;
-
- }
-
- return obj;
- }
-
- public static Type OidToType (int oid) {
- Type typ = null;
-
- switch(oid) {
- case 1043: // varchar
- case 25: // text
- case 18: // char
- typ = typeof(String);
- break;
- case 16: // bool
- typ = typeof(Boolean);
- break;
- case 21: // int2
- typ = typeof(Int16);
- break;
- case 23: // int4
- typ = typeof(Int32);
- break;
- case 20: // int8
- typ = typeof(Int64);
- break;
- default:
- throw new NotImplementedException(
- "PGNI2: PostgreSQL oid type " + oid +
- " not mapped to .NET System Type.");
- }
- return typ;
- }
-
- }
-
- sealed public class PostgresLibrary {
-
- public enum ConnStatusType {
- CONNECTION_OK,
- CONNECTION_BAD,
- CONNECTION_STARTED,
- CONNECTION_MADE,
- CONNECTION_AWAITING_RESPONSE,
- CONNECTION_AUTH_OK,
- CONNECTION_SETENV
- }
-
- public enum PostgresPollingStatusType {
- PGRES_POLLING_FAILED = 0,
- PGRES_POLLING_READING,
- PGRES_POLLING_WRITING,
- PGRES_POLLING_OK,
- PGRES_POLLING_ACTIVE
- }
-
- public enum ExecStatusType {
- PGRES_EMPTY_QUERY = 0,
- PGRES_COMMAND_OK,
- PGRES_TUPLES_OK,
- PGRES_COPY_OUT,
- PGRES_COPY_IN,
- PGRES_BAD_RESPONSE,
- PGRES_NONFATAL_ERROR,
- PGRES_FATAL_ERROR
- }
-
-
- [DllImport("pq")]
- public static extern string PQerrorMessage (IntPtr conn);
- // char *PQerrorMessage(const PGconn *conn);
-
- [DllImport("pq")]
- public static extern IntPtr PQconnectdb(String conninfo);
- // PGconn *PQconnectdb(const char *conninfo)
-
- [DllImport("pq")]
- public static extern void PQfinish(IntPtr conn);
- // void PQfinish(PGconn *conn)
-
- [DllImport("pq")]
- public static extern IntPtr PQexec(IntPtr conn,
- String query);
- // PGresult *PQexec(PGconn *conn, const char *query);
-
- [DllImport("pq")]
- public static extern int PQntuples (IntPtr res);
- // int PQntuples(const PGresult *res);
-
- [DllImport("pq")]
- public static extern int PQnfields (IntPtr res);
- // int PQnfields(const PGresult *res);
-
- [DllImport("pq")]
- public static extern ConnStatusType PQstatus (IntPtr conn);
- // ConnStatusType PQstatus(const PGconn *conn);
- [DllImport("pq")]
- public static extern ExecStatusType PQresultStatus (IntPtr res);
- // ExecStatusType PQresultStatus(const PGresult *res);
-
- [DllImport("pq")]
- public static extern string PQresStatus (ExecStatusType status);
- // char *PQresStatus(ExecStatusType status);
-
- [DllImport("pq")]
- public static extern string PQresultErrorMessage (IntPtr res);
- // char *PQresultErrorMessage(const PGresult *res);
-
- [DllImport("pq")]
- public static extern int PQbinaryTuples (IntPtr res);
- // int PQbinaryTuples(const PGresult *res);
-
- [DllImport("pq")]
- public static extern string PQfname (IntPtr res,
- int field_num);
- // char *PQfname(const PGresult *res,
- // int field_num);
-
- [DllImport("pq")]
- public static extern int PQfnumber (IntPtr res,
- string field_name);
- // int PQfnumber(const PGresult *res,
- // const char *field_name);
-
-
- [DllImport("pq")]
- public static extern int PQfmod (IntPtr res, int field_num);
- // int PQfmod(const PGresult *res, int field_num);
-
- [DllImport("pq")]
- public static extern int PQftype (IntPtr res,
- int field_num);
- // Oid PQftype(const PGresult *res,
- // int field_num);
-
- [DllImport("pq")]
- public static extern int PQfsize (IntPtr res,
- int field_num);
- // int PQfsize(const PGresult *res,
- // int field_num);
-
- [DllImport("pq")]
- public static extern string PQcmdStatus (IntPtr res);
- // char *PQcmdStatus(PGresult *res);
-
- [DllImport("pq")]
- public static extern string PQoidStatus (IntPtr res);
- // char *PQoidStatus(const PGresult *res);
-
- [DllImport("pq")]
- public static extern int PQoidValue (IntPtr res);
- // Oid PQoidValue(const PGresult *res);
-
- [DllImport("pq")]
- public static extern string PQcmdTuples (IntPtr res);
- // char *PQcmdTuples(PGresult *res);
-
- [DllImport("pq")]
- public static extern string PQgetvalue (IntPtr res,
- int tup_num, int field_num);
- // char *PQgetvalue(const PGresult *res,
- // int tup_num, int field_num);
-
- [DllImport("pq")]
- public static extern int PQgetlength (IntPtr res,
- int tup_num, int field_num);
- // int PQgetlength(const PGresult *res,
- // int tup_num, int field_num);
-
- [DllImport("pq")]
- public static extern int PQgetisnull (IntPtr res,
- int tup_num, int field_num);
- // int PQgetisnull(const PGresult *res,
- // int tup_num, int field_num);
-
- [DllImport("pq")]
- public static extern void PQclear (IntPtr res);
- // void PQclear(PGresult *res);
-
-
- }
-
- public class ReadPostgresData
- {
-
- static void Test(String sConnInfo) {
- String errorMessage;
-
- IntPtr pgConn;
- PostgresLibrary.ConnStatusType connStatus;
-
- String sQuery;
- IntPtr pgResult;
-
- sQuery =
- "select tid, tdesc, aint4, abpchar " +
- "from sometable ";
-
- pgConn = PostgresLibrary.PQconnectdb (sConnInfo);
-
- connStatus = PostgresLibrary.PQstatus (pgConn);
- if(connStatus ==
- PostgresLibrary.
- ConnStatusType.CONNECTION_OK) {
-
- Console.WriteLine("CONNECTION_OK");
-
- Console.WriteLine("SQL: " + sQuery);
- pgResult = PostgresLibrary.PQexec(pgConn, sQuery);
-
- PostgresLibrary.ExecStatusType execStatus;
-
- execStatus = PostgresLibrary.
- PQresultStatus (pgResult);
-
- if(execStatus ==
- PostgresLibrary.
- ExecStatusType.PGRES_TUPLES_OK)
- {
- Console.WriteLine("PGRES_TUPLES_OK");
-
- int nRows = PostgresLibrary.
- PQntuples(pgResult);
- Console.WriteLine("Rows: " + nRows);
-
- int nFields = PostgresLibrary.
- PQnfields(pgResult);
- Console.WriteLine("Columns: " + nFields);
-
-
- String fieldName;
-
- // get meta data fromm result set (schema)
- // for each column (field)
- for(int fieldIndex = 0;
- fieldIndex < nFields;
- fieldIndex ++) {
-
- // get column name
- fieldName = PostgresLibrary.
- PQfname(pgResult, fieldIndex);
-
- Console.WriteLine("Field " +
- fieldIndex + ": " +
- fieldName);
-
- int oid;
- // get PostgreSQL data type (OID)
- oid = PostgresLibrary.
- PQftype(pgResult, fieldIndex);
-
- Console.WriteLine("Data Type oid: " + oid);
-
- int definedSize;
- // get defined size of column
- definedSize = PostgresLibrary.
- PQfsize(pgResult, fieldIndex);
-
- Console.WriteLine("definedSize: " +
- definedSize);
- }
-
- // for each row and column, get the data value
- for(int row = 0;
- row < nRows;
- row++) {
-
- for(int col = 0;
- col < nFields;
- col++) {
-
- String value;
- // get data value
- value = PostgresLibrary.
- PQgetvalue(
- pgResult,
- row, col);
-
- Console.WriteLine("Row: " + row +
- " Col: " + col);
- Console.WriteLine("Value: " +
- value);
-
- int columnIsNull;
- // is column NULL?
- columnIsNull = PostgresLibrary.
- PQgetisnull(pgResult,
- row, col);
-
- Console.WriteLine("Data is " +
- (columnIsNull == 0 ? "NOT NULL" : "NULL"));
-
-
- int actualLength;
- // get Actual Length
- actualLength = PostgresLibrary.
- PQgetlength(pgResult,
- row, col);
-
- Console.WriteLine("Actual Length: " +
- actualLength);
- }
- }
-
- // close result set
- PostgresLibrary.PQclear (pgResult);
- }
- else {
- // display execution error
- errorMessage = PostgresLibrary.
- PQresStatus(execStatus);
-
- errorMessage += " " + PostgresLibrary.
- PQresultErrorMessage(pgResult);
-
- Console.WriteLine(errorMessage);
- }
-
- // close database conneciton
- PostgresLibrary.PQfinish(pgConn);
-
- }
- else {
- errorMessage = PostgresLibrary.
- PQerrorMessage (pgConn);
- errorMessage += ": Could not connect to database.";
- Console.WriteLine(errorMessage);
- }
-
- }
-
- public static object ExecuteScalar(string sConnInfo, string sQuery) {
- object obj = null; // return
-
- int nRow;
- int nCol;
-
- String errorMessage;
-
- IntPtr pgConn;
- PostgresLibrary.ConnStatusType connStatus;
-
- IntPtr pgResult;
-
- pgConn = PostgresLibrary.PQconnectdb (sConnInfo);
-
- connStatus = PostgresLibrary.PQstatus (pgConn);
- if(connStatus ==
- PostgresLibrary.
- ConnStatusType.CONNECTION_OK) {
-
- Console.WriteLine("CONNECTION_OK");
-
- pgResult = PostgresLibrary.PQexec(pgConn, sQuery);
-
- PostgresLibrary.ExecStatusType execStatus;
-
- execStatus = PostgresLibrary.
- PQresultStatus (pgResult);
-
- if(execStatus ==
- PostgresLibrary.
- ExecStatusType.PGRES_TUPLES_OK) {
-
- Console.WriteLine("PGRES_TUPLES_OK");
-
- int nRows = PostgresLibrary.
- PQntuples(pgResult);
- Console.WriteLine("Rows: " + nRows);
-
- int nFields = PostgresLibrary.
- PQnfields(pgResult);
- Console.WriteLine("Columns: " + nFields);
- if(nRows > 0 && nFields > 0) {
- nRow = 0;
- nCol = 0;
-
- // get column name
- String fieldName;
- fieldName = PostgresLibrary.
- PQfname(pgResult, nCol);
-
- Console.WriteLine("Field " +
- nCol + ": " +
- fieldName);
-
- int oid;
-
- // get PostgreSQL data type (OID)
- oid = PostgresLibrary.
- PQftype(pgResult, nCol);
-
- Console.WriteLine("Data Type oid: " + oid);
-
- int definedSize;
- // get defined size of column
- definedSize = PostgresLibrary.
- PQfsize(pgResult, nCol);
-
- Console.WriteLine("DefinedSize: " +
- definedSize);
-
- String value;
- // get data value
- value = PostgresLibrary.
- PQgetvalue(
- pgResult,
- nRow, nCol);
-
- Console.WriteLine("Row: " + nRow +
- " Col: " + nCol);
- Console.WriteLine("Value: " + value);
-
- int columnIsNull;
- // is column NULL?
- columnIsNull = PostgresLibrary.
- PQgetisnull(pgResult,
- nRow, nCol);
-
- // isNull = *thevalue != '\0' ? FALSE : PQgetisnull (pg_res, rownum, i);
-
- Console.WriteLine("Data is " +
- (columnIsNull == 0 ? "NOT NULL" : "NULL"));
-
- int actualLength;
- // get Actual Length
- actualLength = PostgresLibrary.
- PQgetlength(pgResult,
- nRow, nCol);
-
- Console.WriteLine("Actual Length: " +
- actualLength);
-
- obj = PostgresHelper.
- OidTypeToSystem (oid, value);
- }
-
- // close result set
- PostgresLibrary.PQclear (pgResult);
- }
- else {
- // display execution error
- errorMessage = PostgresLibrary.
- PQresStatus(execStatus);
-
- errorMessage += " " + PostgresLibrary.
- PQresultErrorMessage(pgResult);
-
- Console.WriteLine(errorMessage);
- }
-
- // close database conneciton
- PostgresLibrary.PQfinish(pgConn);
-
- }
- else {
- errorMessage = PostgresLibrary.
- PQerrorMessage (pgConn);
- errorMessage += ": Could not connect to database.";
- Console.WriteLine(errorMessage);
- }
-
- return obj;
- }
-
- static void TestExecuteScalar(String connString) {
- String selectStatement;
-
- try {
- selectStatement =
- "select count(*) " +
- "from sometable";
-
- Int64 myCount = (Int64) ExecuteScalar(connString,
- selectStatement);
- Console.WriteLine("Count: " + myCount);
-
- selectStatement =
- "select max(tdesc) " +
- "from sometable";
- string myMax = (string) ExecuteScalar(connString,
- selectStatement);
- Console.WriteLine("Max: " + myMax);
- }
- catch(Exception e) {
- Console.WriteLine(e);
- }
-
- }
-
- [STAThread]
- static void Main(string[] args)
- {
- // PostgreSQL DBMS Connection String
- // Notice how the parameters are separated with spaces
- // An OLE-DB Connection String uses semicolons to
- // separate parameters.
- String sConnInfo =
- "host=localhost " +
- "dbname=test " +
- "user=postgres";
-
- Test(sConnInfo);
-
- TestExecuteScalar(sConnInfo);
-
- Type t;
- int oid;
-
- oid = 1043;
- t = PostgresHelper.OidToType(oid); // varchar ==> String
- Console.WriteLine("OidToType varchar oid: " + oid +
- " ==> t: " + t.ToString());
-
- oid = 23;
- t = PostgresHelper.OidToType(oid); // int4 ==> Int32
- Console.WriteLine("OidToType int4 oid: " + oid +
- " ==> t: " + t.ToString());
-
- }
- }
-}
generated by cgit v1.2.3 (git 2.25.1) at 2024-07-20 21:22:44 +0300