[pgsqlclient-checkins] pgsqlclient_10/PostgreSql.Data.PgSqlClient.UnitTests/source PgBaseTest.cs,1.8
Status: Inactive
Brought to you by:
carlosga_fb
Menu
▾
▴
[pgsqlclient-checkins] pgsqlclient_10/PostgreSql.Data.PgSqlClient.UnitTests/source PgBaseTest.cs,1.8,1.9
|
From: <car...@us...> - 2003-12-18 10:10:51
|
Update of /cvsroot/pgsqlclient/pgsqlclient_10/PostgreSql.Data.PgSqlClient.UnitTests/source
In directory sc8-pr-cvs1:/tmp/cvs-serv7987
Modified Files:
PgBaseTest.cs
Log Message:
Updated file
Index: PgBaseTest.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient_10/PostgreSql.Data.PgSqlClient.UnitTests/source/PgBaseTest.cs,v
retrieving revision 1.8
retrieving revision 1.9
diff -C2 -d -r1.8 -r1.9
*** PgBaseTest.cs 20 Nov 2003 17:35:31 -0000 1.8
--- PgBaseTest.cs 18 Dec 2003 10:10:47 -0000 1.9
***************
*** 1,368 ****
! /* PgSqlClient - ADO.NET Data Provider for PostgreSQL 7.4+
! * Copyright (C) 2003 Carlos Guzmán Álvarez
! *
! * This library is free software; you can redistribute it and/or
! * modify it under the terms of the GNU Lesser General Public
! * License as published by the Free Software Foundation; either
! * version 2.1 of the License, or (at your option) any later version.
! *
! * This library is distributed in the hope that it will be useful,
! * but WITHOUT ANY WARRANTY; without even the implied warranty of
! * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
! * Lesser General Public License for more details.
! *
! * You should have received a copy of the GNU Lesser General Public
! * License along with this library; if not, write to the Free Software
! * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
! */
!
! using System;
! using System.Text;
! using System.Data;
! using System.Configuration;
! using NUnit.Framework;
!
! using PostgreSql.Data.PgSqlClient;
! using PostgreSql.Data.PgTypes;
!
! namespace PostgreSql.Data.PgSqlClient.UnitTests
! {
! public class PgBaseTest
! {
! private PgConnection connection;
!
! public PgConnection Connection
! {
! get { return connection; }
! }
!
! public PgBaseTest()
! {
! }
!
! [SetUp]
! public void SetUp()
! {
! try
! {
! dropDatabase();
! }
! catch{}
!
! createDatabase();
!
! // Build the connection string
! StringBuilder connString = new StringBuilder();
! connString.AppendFormat(
! "User={0};Password={1};Database={2};DataSource={3};Port={4};SSL={5}",
! ConfigurationSettings.AppSettings["User"],
! ConfigurationSettings.AppSettings["Password"],
! ConfigurationSettings.AppSettings["Database"],
! ConfigurationSettings.AppSettings["DataSource"],
! ConfigurationSettings.AppSettings["Port"],
! ConfigurationSettings.AppSettings["SSL"]);
!
! connection = new PgConnection(connString.ToString());
! connection.StateChange += new StateChangeEventHandler(stateChange);
! connection.Open();
!
! createTables();
! createFunctions();
! }
!
! [TearDown]
! public void TearDown()
! {
! connection.Close();
! }
!
! private void stateChange(object sender, StateChangeEventArgs e)
! {
! Console.WriteLine("Connection state changed from {0} to {1}",
! e.OriginalState, e.CurrentState);
! }
!
! private void createDatabase()
! {
! StringBuilder connString = new StringBuilder();
! connString.AppendFormat(
! "User={0};Password={1};Database={2};DataSource={3};Port={4};SSL={5}",
! ConfigurationSettings.AppSettings["User"],
! ConfigurationSettings.AppSettings["Password"],
! String.Empty,
! ConfigurationSettings.AppSettings["DataSource"],
! ConfigurationSettings.AppSettings["Port"],
! ConfigurationSettings.AppSettings["SSL"]);
!
! PgConnection connection = new PgConnection(connString.ToString());
! connection.Open();
!
! connection.CreateDatabase(
! ConfigurationSettings.AppSettings["Database"],
! null,
! null,
! null,
! "UNICODE");
!
! connection.Close();
! }
!
! private void dropDatabase()
! {
! StringBuilder connString = new StringBuilder();
! connString.AppendFormat(
! "User={0};Password={1};Database={2};DataSource={3};Port={4};SSL={5}",
! ConfigurationSettings.AppSettings["User"],
! ConfigurationSettings.AppSettings["Password"],
! String.Empty,
! ConfigurationSettings.AppSettings["DataSource"],
! ConfigurationSettings.AppSettings["Port"],
! ConfigurationSettings.AppSettings["SSL"]);
!
! PgConnection connection = new PgConnection(connString.ToString());
! connection.Open();
!
! StringBuilder commandText = new StringBuilder();
!
! commandText.AppendFormat(
! "drop database {0}",
! ConfigurationSettings.AppSettings["Database"]);
!
! PgCommand command = new PgCommand(commandText.ToString(), connection);
!
! command.ExecuteNonQuery();
! command.Dispose();
!
! connection.Close();
! }
!
! private void createTables()
! {
! StringBuilder commandText = new StringBuilder();
!
! // Table for general purpouse tests
! commandText.Append("CREATE TABLE public.test_table(");
! commandText.Append("int4_field int4 NOT NULL,");
! commandText.Append("char_field char(10),");
! commandText.Append("varchar_field varchar(30),");
! commandText.Append("single_field float4,");
! commandText.Append("double_field float8,");
! commandText.Append("date_field date,");
! commandText.Append("time_field time,");
! commandText.Append("timestamp_field timestamp,");
! commandText.Append("blob_field bytea,");
! commandText.Append("bool_field bool,");
! commandText.Append("int2_field int2,");
! commandText.Append("int8_field int8,");
! commandText.Append("money_field money,");
! commandText.Append("numeric_field numeric(8,2),");
! commandText.Append("bool_array bool[],");
! commandText.Append("int2_array int2[],");
! commandText.Append("int4_array int4[],");
! commandText.Append("int8_array int8[],");
! commandText.Append("mint2_array int2[][],");
! commandText.Append("serial_field serial NOT NULL,");
! commandText.Append("macaddr_field macaddr,");
! commandText.Append("inet_field inet,");
! commandText.Append("name_field name,");
! commandText.Append("CONSTRAINT test_table_pkey PRIMARY KEY (int4_field)");
! commandText.Append(") WITH OIDS;");
!
! PgCommand command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! commandText = new StringBuilder();
!
! // Table for Geometric types tests
! commandText.Append("CREATE TABLE public.geometric_table(");
! commandText.Append("pk int4 NOT NULL,");
! commandText.Append("point_field point,");
! commandText.Append("box_field box,");
! commandText.Append("circle_field circle,");
! commandText.Append("lseg_field lseg,");
! commandText.Append("path_field path,");
! commandText.Append("polygon_field polygon,");
! commandText.Append("point_array point[],");
! commandText.Append("box_array box[],");
! commandText.Append("circle_array circle[],");
! commandText.Append("lseg_array lseg[],");
! commandText.Append("path_array path[],");
! commandText.Append("polygon_array polygon[],");
! commandText.Append("line_field line,");
! commandText.Append("line_array line[],");
! commandText.Append("CONSTRAINT geometric_test_pkey PRIMARY KEY (pk)");
! commandText.Append(") WITH OIDS;");
!
! command.CommandText = commandText.ToString();
! command.ExecuteNonQuery();
! command.Dispose();
!
! insertTestData();
! insertGeometricTestData();
! }
!
! private void createFunctions()
! {
! // Create language functions
! StringBuilder commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.plpgsql_call_handler()");
! commandText.Append("RETURNS language_handler AS");
! commandText.Append("'$libdir/plpgsql', 'plpgsql_call_handler'");
! commandText.Append("LANGUAGE 'c' VOLATILE;");
!
! PgCommand command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! // Create languages
! commandText = new StringBuilder();
!
! commandText.Append("CREATE TRUSTED PROCEDURAL LANGUAGE 'plpgsql' HANDLER plpgsql_call_handler;");
!
! command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! // Create test function public.TestCount()
! commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.TestCount()");
! commandText.Append("RETURNS int8 AS");
! commandText.Append("'");
! commandText.Append("select count(*) from test_table;");
! commandText.Append("'");
! commandText.Append("LANGUAGE 'sql' VOLATILE;");
!
! command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! // Create test function public.DeriveCount()
! commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.DeriveCount(int4)");
! commandText.Append("RETURNS int8 AS");
! commandText.Append("'");
! commandText.Append("select count(*) from test_table where int4_field < $1;");
! commandText.Append("'");
! commandText.Append("LANGUAGE 'sql' VOLATILE;");
!
! command.CommandText = commandText.ToString();
! command.ExecuteNonQuery();
!
! // Create test function public.DeleteRows()
! commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.DeleteRows(int4)\r\n");
! commandText.Append("RETURNS BOOLEAN AS '\r\n");
! commandText.Append("DECLARE\r\n");
! commandText.Append("\t\trows INTEGER;\r\n");
! commandText.Append("BEGIN\r\n");
! commandText.Append("DELETE FROM public.test_table WHERE int4_field > $1;\r\n");
! commandText.Append("GET DIAGNOSTICS rows = ROW_COUNT;\r\n");
! commandText.Append("IF rows > 0 THEN\r\n");
! commandText.Append("\t\tRETURN TRUE;\r\n");
! commandText.Append("ELSE\r\n");
! commandText.Append("\t\tRETURN FALSE;\r\n");
! commandText.Append("END IF;\r\n");
! commandText.Append("END;\r\n");
! commandText.Append("'\r\n");
! commandText.Append("LANGUAGE 'plpgsql' VOLATILE;");
!
! command.CommandText = commandText.ToString();
! command.ExecuteNonQuery();
!
! command.Dispose();
! }
!
! private void insertTestData()
! {
! string commandText = "insert into public.test_table values(@int4_field, @char_field, @varchar_field, @single_field, @double_field, @date_Field, @time_field, @timestamp_field)";
!
! PgTransaction transaction = connection.BeginTransaction();
! PgCommand command = new PgCommand(commandText, connection, transaction);
!
! try
! {
! // Add command parameters
! command.Parameters.Add("@int4_field", PgDbType.Int4);
! command.Parameters.Add("@char_field", PgDbType.Char);
! command.Parameters.Add("@varchar_field", PgDbType.VarChar);
! command.Parameters.Add("@single_field", PgDbType.Float);
! command.Parameters.Add("@double_field", PgDbType.Double);
! command.Parameters.Add("@date_field", PgDbType.Date);
! command.Parameters.Add("@time_field", PgDbType.Time);
! command.Parameters.Add("@timestamp_field", PgDbType.Timestamp);
!
! for (int i = 0; i < 100; i++)
! {
! command.Parameters["@int4_field"].Value = i;
! command.Parameters["@char_field"].Value = "IRow " + i.ToString();
! command.Parameters["@varchar_field"].Value = "IRow Number" + i.ToString();
! command.Parameters["@single_field"].Value = (float)(i + 10)/5;
! command.Parameters["@double_field"].Value = Math.Log(i, 10);
! command.Parameters["@date_field"].Value = DateTime.Now;
! command.Parameters["@time_field"].Value = DateTime.Now;
! command.Parameters["@timestamp_field"].Value = DateTime.Now;
!
! command.ExecuteNonQuery();
! }
!
! // Commit transaction
! transaction.Commit();
! }
! catch (PgException ex)
! {
! transaction.Rollback();
! throw ex;
! }
! finally
! {
! command.Dispose();
! }
! }
!
! private void insertGeometricTestData()
! {
! string commandText = "insert into public.geometric_table values(@pk, @point, @box, @circle, @lseg, @path, @polygon)";
!
! PgTransaction transaction = connection.BeginTransaction();
! PgCommand command = new PgCommand(commandText, connection, transaction);
!
! try
! {
! // Add command parameters
! command.Parameters.Add("@pk", PgDbType.Int4);
! command.Parameters.Add("@point", PgDbType.Point);
! command.Parameters.Add("@box", PgDbType.Box);
! command.Parameters.Add("@circle", PgDbType.Circle);
! command.Parameters.Add("@lseg", PgDbType.LSeg);
! command.Parameters.Add("@path", PgDbType.Path);
! command.Parameters.Add("@polygon", PgDbType.Polygon);
!
! for (int i = 0; i < 100; i++)
! {
! command.Parameters["@pk"].Value = i;
! command.Parameters["@point"].Value = new PgPoint(i, i + 10);
! command.Parameters["@box"].Value = new PgBox(new PgPoint(0,i), new PgPoint(i, i));
! command.Parameters["@circle"].Value = new PgCircle(new PgPoint(i, 0), i);
! command.Parameters["@lseg"].Value = new PgLSeg(new PgPoint(-1,0), new PgPoint(1,0));
! command.Parameters["@path"].Value = new PgPath(false, new PgPoint[]{new PgPoint(0,0), new PgPoint(1,0)});
! command.Parameters["@polygon"].Value= new PgPolygon(new PgPoint[]{new PgPoint(1,1), new PgPoint(0,0)});
!
! command.ExecuteNonQuery();
! }
!
! // Commit transaction
! transaction.Commit();
! }
! catch (PgException ex)
! {
! transaction.Rollback();
! throw ex;
! }
! finally
! {
! command.Dispose();
! }
! }
! }
}
--- 1,368 ----
! /* PgSqlClient - ADO.NET Data Provider for PostgreSQL 7.4+
! * Copyright (C) 2003 Carlos Guzmán Álvarez
! *
! * This library is free software; you can redistribute it and/or
! * modify it under the terms of the GNU Lesser General Public
! * License as published by the Free Software Foundation; either
! * version 2.1 of the License, or (at your option) any later version.
! *
! * This library is distributed in the hope that it will be useful,
! * but WITHOUT ANY WARRANTY; without even the implied warranty of
! * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
! * Lesser General Public License for more details.
! *
! * You should have received a copy of the GNU Lesser General Public
! * License along with this library; if not, write to the Free Software
! * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
! */
!
! using System;
! using System.Text;
! using System.Data;
! using System.Configuration;
! using NUnit.Framework;
!
! using PostgreSql.Data.PgSqlClient;
! using PostgreSql.Data.PgTypes;
!
! namespace PostgreSql.Data.PgSqlClient.UnitTests
! {
! public class PgBaseTest
! {
! private PgConnection connection;
!
! public PgConnection Connection
! {
! get { return connection; }
! }
!
! public PgBaseTest()
! {
! }
!
! [SetUp]
! public void SetUp()
! {
! try
! {
! dropDatabase();
! }
! catch{}
!
! createDatabase();
!
! // Build the connection string
! StringBuilder connString = new StringBuilder();
! connString.AppendFormat(
! "User={0};Password={1};Database={2};DataSource={3};Port={4};SSL={5}",
! ConfigurationSettings.AppSettings["User"],
! ConfigurationSettings.AppSettings["Password"],
! ConfigurationSettings.AppSettings["Database"],
! ConfigurationSettings.AppSettings["DataSource"],
! ConfigurationSettings.AppSettings["Port"],
! ConfigurationSettings.AppSettings["SSL"]);
!
! connection = new PgConnection(connString.ToString());
! connection.StateChange += new StateChangeEventHandler(stateChange);
! connection.Open();
!
! createTables();
! createFunctions();
! }
!
! [TearDown]
! public void TearDown()
! {
! connection.Close();
! }
!
! private void stateChange(object sender, StateChangeEventArgs e)
! {
! Console.WriteLine("Connection state changed from {0} to {1}",
! e.OriginalState, e.CurrentState);
! }
!
! private void createDatabase()
! {
! StringBuilder connString = new StringBuilder();
! connString.AppendFormat(
! "User={0};Password={1};Database={2};DataSource={3};Port={4};SSL={5}",
! ConfigurationSettings.AppSettings["User"],
! ConfigurationSettings.AppSettings["Password"],
! String.Empty,
! ConfigurationSettings.AppSettings["DataSource"],
! ConfigurationSettings.AppSettings["Port"],
! ConfigurationSettings.AppSettings["SSL"]);
!
! PgConnection connection = new PgConnection(connString.ToString());
! connection.Open();
!
! connection.CreateDatabase(
! ConfigurationSettings.AppSettings["Database"],
! null,
! null,
! null,
! "UNICODE");
!
! connection.Close();
! }
!
! private void dropDatabase()
! {
! StringBuilder connString = new StringBuilder();
! connString.AppendFormat(
! "User={0};Password={1};Database={2};DataSource={3};Port={4};SSL={5}",
! ConfigurationSettings.AppSettings["User"],
! ConfigurationSettings.AppSettings["Password"],
! String.Empty,
! ConfigurationSettings.AppSettings["DataSource"],
! ConfigurationSettings.AppSettings["Port"],
! ConfigurationSettings.AppSettings["SSL"]);
!
! PgConnection connection = new PgConnection(connString.ToString());
! connection.Open();
!
! StringBuilder commandText = new StringBuilder();
!
! commandText.AppendFormat(
! "drop database {0}",
! ConfigurationSettings.AppSettings["Database"]);
!
! PgCommand command = new PgCommand(commandText.ToString(), connection);
!
! command.ExecuteNonQuery();
! command.Dispose();
!
! connection.Close();
! }
!
! private void createTables()
! {
! StringBuilder commandText = new StringBuilder();
!
! // Table for general purpouse tests
! commandText.Append("CREATE TABLE public.test_table(");
! commandText.Append("int4_field int4 NOT NULL,");
! commandText.Append("char_field char(10),");
! commandText.Append("varchar_field varchar(30),");
! commandText.Append("single_field float4,");
! commandText.Append("double_field float8,");
! commandText.Append("date_field date,");
! commandText.Append("time_field time,");
! commandText.Append("timestamp_field timestamp,");
! commandText.Append("blob_field bytea,");
! commandText.Append("bool_field bool,");
! commandText.Append("int2_field int2,");
! commandText.Append("int8_field int8,");
! commandText.Append("money_field money,");
! commandText.Append("numeric_field numeric(8,2),");
! commandText.Append("bool_array bool[],");
! commandText.Append("int2_array int2[],");
! commandText.Append("int4_array int4[],");
! commandText.Append("int8_array int8[],");
! commandText.Append("mint2_array int2[][],");
! commandText.Append("serial_field serial NOT NULL,");
! commandText.Append("macaddr_field macaddr,");
! commandText.Append("inet_field inet,");
! commandText.Append("name_field name,");
! commandText.Append("CONSTRAINT test_table_pkey PRIMARY KEY (int4_field)");
! commandText.Append(") WITH OIDS;");
!
! PgCommand command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! commandText = new StringBuilder();
!
! // Table for Geometric types tests
! commandText.Append("CREATE TABLE public.geometric_table(");
! commandText.Append("pk int4 NOT NULL,");
! commandText.Append("point_field point,");
! commandText.Append("box_field box,");
! commandText.Append("circle_field circle,");
! commandText.Append("lseg_field lseg,");
! commandText.Append("path_field path,");
! commandText.Append("polygon_field polygon,");
! commandText.Append("point_array point[],");
! commandText.Append("box_array box[],");
! commandText.Append("circle_array circle[],");
! commandText.Append("lseg_array lseg[],");
! commandText.Append("path_array path[],");
! commandText.Append("polygon_array polygon[],");
! commandText.Append("line_field line,");
! commandText.Append("line_array line[],");
! commandText.Append("CONSTRAINT geometric_test_pkey PRIMARY KEY (pk)");
! commandText.Append(") WITH OIDS;");
!
! command.CommandText = commandText.ToString();
! command.ExecuteNonQuery();
! command.Dispose();
!
! insertTestData();
! insertGeometricTestData();
! }
!
! private void createFunctions()
! {
! // Create language functions
! StringBuilder commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.plpgsql_call_handler()");
! commandText.Append("RETURNS language_handler AS");
! commandText.Append("'$libdir/plpgsql', 'plpgsql_call_handler'");
! commandText.Append("LANGUAGE 'c' VOLATILE;");
!
! PgCommand command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! // Create languages
! commandText = new StringBuilder();
!
! commandText.Append("CREATE TRUSTED PROCEDURAL LANGUAGE 'plpgsql' HANDLER plpgsql_call_handler;");
!
! command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! // Create test function public.TestCount()
! commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.TestCount()");
! commandText.Append("RETURNS int8 AS");
! commandText.Append("'");
! commandText.Append("select count(*) from test_table;");
! commandText.Append("'");
! commandText.Append("LANGUAGE 'sql' VOLATILE;");
!
! command = new PgCommand(commandText.ToString(), connection);
! command.ExecuteNonQuery();
!
! // Create test function public.DeriveCount()
! commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.DeriveCount(int4)");
! commandText.Append("RETURNS int8 AS");
! commandText.Append("'");
! commandText.Append("select count(*) from test_table where int4_field < $1;");
! commandText.Append("'");
! commandText.Append("LANGUAGE 'sql' VOLATILE;");
!
! command.CommandText = commandText.ToString();
! command.ExecuteNonQuery();
!
! // Create test function public.DeleteRows()
! commandText = new StringBuilder();
!
! commandText.Append("CREATE OR REPLACE FUNCTION public.DeleteRows(int4)\r\n");
! commandText.Append("RETURNS BOOLEAN AS '\r\n");
! commandText.Append("DECLARE\r\n");
! commandText.Append("\t\trows INTEGER;\r\n");
! commandText.Append("BEGIN\r\n");
! commandText.Append("DELETE FROM public.test_table WHERE int4_field > $1;\r\n");
! commandText.Append("GET DIAGNOSTICS rows = ROW_COUNT;\r\n");
! commandText.Append("IF rows > 0 THEN\r\n");
! commandText.Append("\t\tRETURN TRUE;\r\n");
! commandText.Append("ELSE\r\n");
! commandText.Append("\t\tRETURN FALSE;\r\n");
! commandText.Append("END IF;\r\n");
! commandText.Append("END;\r\n");
! commandText.Append("'\r\n");
! commandText.Append("LANGUAGE 'plpgsql' VOLATILE;");
!
! command.CommandText = commandText.ToString();
! command.ExecuteNonQuery();
!
! command.Dispose();
! }
!
! private void insertTestData()
! {
! string commandText = "insert into public.test_table values(@int4_field, @char_field, @varchar_field, @single_field, @double_field, @date_Field, @time_field, @timestamp_field)";
!
! PgTransaction transaction = connection.BeginTransaction();
! PgCommand command = new PgCommand(commandText, connection, transaction);
!
! try
! {
! // Add command parameters
! command.Parameters.Add("@int4_field", PgDbType.Int4);
! command.Parameters.Add("@char_field", PgDbType.Char);
! command.Parameters.Add("@varchar_field", PgDbType.VarChar);
! command.Parameters.Add("@single_field", PgDbType.Float);
! command.Parameters.Add("@double_field", PgDbType.Double);
! command.Parameters.Add("@date_field", PgDbType.Date);
! command.Parameters.Add("@time_field", PgDbType.Time);
! command.Parameters.Add("@timestamp_field", PgDbType.Timestamp);
!
! for (int i = 0; i < 100; i++)
! {
! command.Parameters["@int4_field"].Value = i;
! command.Parameters["@char_field"].Value = "IRow " + i.ToString();
! command.Parameters["@varchar_field"].Value = "IRow Number" + i.ToString();
! command.Parameters["@single_field"].Value = (float)(i + 10)/5;
! command.Parameters["@double_field"].Value = Math.Log(i, 10);
! command.Parameters["@date_field"].Value = DateTime.Now;
! command.Parameters["@time_field"].Value = DateTime.Now;
! command.Parameters["@timestamp_field"].Value = DateTime.Now;
!
! command.ExecuteNonQuery();
! }
!
! // Commit transaction
! transaction.Commit();
! }
! catch (PgException ex)
! {
! transaction.Rollback();
! throw ex;
! }
! finally
! {
! command.Dispose();
! }
! }
!
! private void insertGeometricTestData()
! {
! string commandText = "insert into public.geometric_table values(@pk, @point, @box, @circle, @lseg, @path, @polygon)";
!
! PgTransaction transaction = connection.BeginTransaction();
! PgCommand command = new PgCommand(commandText, connection, transaction);
!
! try
! {
! // Add command parameters
! command.Parameters.Add("@pk", PgDbType.Int4);
! command.Parameters.Add("@point", PgDbType.Point);
! command.Parameters.Add("@box", PgDbType.Box);
! command.Parameters.Add("@circle", PgDbType.Circle);
! command.Parameters.Add("@lseg", PgDbType.LSeg);
! command.Parameters.Add("@path", PgDbType.Path);
! command.Parameters.Add("@polygon", PgDbType.Polygon);
!
! for (int i = 0; i < 100; i++)
! {
! command.Parameters["@pk"].Value = i;
! command.Parameters["@point"].Value = new PgPoint(i, i + 10);
! command.Parameters["@box"].Value = new PgBox(new PgPoint(0,i), new PgPoint(i, i));
! command.Parameters["@circle"].Value = new PgCircle(new PgPoint(i, 0), i);
! command.Parameters["@lseg"].Value = new PgLSeg(new PgPoint(-1,0), new PgPoint(1,0));
! command.Parameters["@path"].Value = new PgPath(false, new PgPoint[]{new PgPoint(0,0), new PgPoint(1,0)});
! command.Parameters["@polygon"].Value= new PgPolygon(new PgPoint[]{new PgPoint(1,1), new PgPoint(0,0)});
!
! command.ExecuteNonQuery();
! }
!
! // Commit transaction
! transaction.Commit();
! }
! catch (PgException ex)
! {
! transaction.Rollback();
! throw ex;
! }
! finally
! {
! command.Dispose();
! }
! }
! }
}
|
