-// created on 30/11/2002 at 22:35\r
-using System;\r
-using Npgsql;\r
-using NUnit.Framework;\r
-using NUnit.Core;\r
-using System.Data;\r
-using NpgsqlTypes;\r
-\r
-namespace NpgsqlTests\r
-{\r
- \r
- [TestFixture]\r
- public class CommandTests\r
- {\r
- private NpgsqlConnection _conn = null;\r
- private String _connString = "Server=localhost;User ID=npgsql_tests;Password=npgsql_tests;Database=npgsql_tests";\r
- \r
- [SetUp]\r
- protected void SetUp()\r
- {\r
- NpgsqlEventLog.Level = LogLevel.None;\r
- //NpgsqlEventLog.Level = LogLevel.Debug;\r
- //NpgsqlEventLog.LogName = "NpgsqlTests.LogFile";\r
- _conn = new NpgsqlConnection(_connString);\r
- }\r
- \r
- [TearDown]\r
- protected void TearDown()\r
- {\r
- if (_conn.State != ConnectionState.Closed)\r
- _conn.Close();\r
- }\r
- \r
- \r
- [Test]\r
- public void ParametersGetName()\r
- {\r
- NpgsqlCommand command = new NpgsqlCommand();\r
- \r
- // Add parameters.\r
- command.Parameters.Add(new NpgsqlParameter("Parameter1", DbType.Boolean));\r
- command.Parameters.Add(new NpgsqlParameter("Parameter2", DbType.Int32));\r
- command.Parameters.Add(new NpgsqlParameter("Parameter3", DbType.DateTime));\r
- \r
- \r
- // Get by indexers.\r
- \r
- Assertion.AssertEquals("ParametersGetName", "Parameter1", command.Parameters["Parameter1"].ParameterName);\r
- Assertion.AssertEquals("ParametersGetName", "Parameter2", command.Parameters["Parameter2"].ParameterName);\r
- Assertion.AssertEquals("ParametersGetName", "Parameter3", command.Parameters["Parameter3"].ParameterName);\r
- \r
-\r
- Assertion.AssertEquals("ParametersGetName", "Parameter1", command.Parameters[0].ParameterName);\r
- Assertion.AssertEquals("ParametersGetName", "Parameter2", command.Parameters[1].ParameterName);\r
- Assertion.AssertEquals("ParametersGetName", "Parameter3", command.Parameters[2].ParameterName); \r
- \r
- \r
- \r
- }\r
- \r
- [Test]\r
- [ExpectedException(typeof(NpgsqlException))]\r
- public void NoNameParameterAdd()\r
- {\r
- NpgsqlCommand command = new NpgsqlCommand();\r
- \r
- command.Parameters.Add(new NpgsqlParameter());\r
- \r
- }\r
- \r
- [Test]\r
- public void FunctionCallFromSelect()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("select * from funcB()", _conn);\r
- \r
- NpgsqlDataReader reader = command.ExecuteReader();\r
- \r
- Assertion.AssertNotNull(reader);\r
- //reader.FieldCount\r
- \r
- }\r
- \r
- [Test]\r
- public void ExecuteScalar()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("select count(*) from tablea", _conn);\r
- \r
- Object result = command.ExecuteScalar();\r
- \r
- Assertion.AssertEquals(5, result);\r
- //reader.FieldCount\r
- \r
- }\r
- \r
- [Test]\r
- public void FunctionCallReturnSingleValue()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("funcC()", _conn);\r
- command.CommandType = CommandType.StoredProcedure;\r
- \r
- Object result = command.ExecuteScalar();\r
- \r
- Assertion.AssertEquals(5, result);\r
- //reader.FieldCount\r
- \r
- }\r
- \r
- \r
- [Test]\r
- public void FunctionCallReturnSingleValueWithPrepare()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("funcC()", _conn);\r
- command.CommandType = CommandType.StoredProcedure;\r
- \r
- command.Prepare();\r
- Object result = command.ExecuteScalar();\r
- \r
- Assertion.AssertEquals(5, result);\r
- //reader.FieldCount\r
- \r
- }\r
- \r
- [Test]\r
- public void FunctionCallWithParametersReturnSingleValue()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("funcC(:a)", _conn);\r
- command.CommandType = CommandType.StoredProcedure;\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));\r
- \r
- command.Parameters[0].Value = 4;\r
- \r
- Int64 result = (Int64) command.ExecuteScalar();\r
- \r
- Assertion.AssertEquals(1, result);\r
- \r
- \r
- }\r
- \r
- \r
- [Test]\r
- public void FunctionCallWithParametersPrepareReturnSingleValue()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("funcC(:a)", _conn);\r
- command.CommandType = CommandType.StoredProcedure;\r
- \r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));\r
- \r
- Assertion.AssertEquals(1, command.Parameters.Count);\r
- command.Prepare();\r
- \r
- \r
- command.Parameters[0].Value = 4;\r
- \r
- Int64 result = (Int64) command.ExecuteScalar();\r
- \r
- Assertion.AssertEquals(1, result);\r
- \r
- \r
- }\r
- \r
- [Test]\r
- public void FunctionCallReturnResultSet()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("funcB()", _conn);\r
- command.CommandType = CommandType.StoredProcedure;\r
- \r
- NpgsqlDataReader dr = command.ExecuteReader();\r
- \r
- \r
- \r
- \r
- }\r
- \r
- \r
- [Test]\r
- public void CursorStatement()\r
- {\r
- \r
- _conn.Open();\r
- \r
- Int32 i = 0;\r
- \r
- NpgsqlTransaction t = _conn.BeginTransaction();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("declare te cursor for select * from tablea;", _conn);\r
- \r
- command.ExecuteNonQuery();\r
- \r
- command.CommandText = "fetch forward 3 in te;";\r
- \r
- NpgsqlDataReader dr = command.ExecuteReader();\r
- \r
- \r
- while (dr.Read())\r
- {\r
- i++;\r
- }\r
- \r
- Assertion.AssertEquals(3, i);\r
- \r
- \r
- i = 0;\r
- \r
- command.CommandText = "fetch backward 1 in te;";\r
- \r
- NpgsqlDataReader dr2 = command.ExecuteReader();\r
- \r
- while (dr2.Read())\r
- {\r
- i++;\r
- }\r
- \r
- Assertion.AssertEquals(1, i);\r
- \r
- command.CommandText = "close te;";\r
- \r
- command.ExecuteNonQuery();\r
- \r
- t.Commit();\r
- \r
- \r
- \r
- }\r
- \r
- [Test]\r
- public void PreparedStatementNoParameters()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("select * from tablea;", _conn);\r
- \r
- command.Prepare();\r
- \r
- command.Prepare();\r
- \r
- NpgsqlDataReader dr = command.ExecuteReader();\r
- \r
- \r
- }\r
- \r
- [Test]\r
- public void PreparedStatementWithParameters()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("select * from tablea where field_int4 = :a and field_int8 = :b;", _conn);\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));\r
- command.Parameters.Add(new NpgsqlParameter("b", DbType.Int64));\r
- \r
- Assertion.AssertEquals(2, command.Parameters.Count);\r
- \r
- Assertion.AssertEquals(DbType.Int32, command.Parameters[0].DbType);\r
- \r
- command.Prepare();\r
- \r
- command.Parameters[0].Value = 3;\r
- command.Parameters[1].Value = 5;\r
- \r
- NpgsqlDataReader dr = command.ExecuteReader();\r
- \r
- \r
- \r
- \r
- }\r
- \r
- [Test]\r
- public void DateTimeSupport()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("select field_timestamp from tableb where field_serial = 2;", _conn);\r
- \r
- DateTime d = (DateTime)command.ExecuteScalar();\r
- \r
- \r
- Assertion.AssertEquals("2002-02-02 09:00:23Z", d.ToString("u"));\r
- \r
- \r
- }\r
- \r
- [Test]\r
- public void NumericSupport()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_numeric) values (:a)", _conn);\r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Decimal));\r
- \r
- command.Parameters[0].Value = 7.4M;\r
- \r
- Int32 rowsAdded = command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(1, rowsAdded);\r
- \r
- command.CommandText = "select * from tableb where field_numeric = :a";\r
- \r
- \r
- NpgsqlDataReader dr = command.ExecuteReader();\r
- dr.Read();\r
- \r
- Decimal result = dr.GetDecimal(3);\r
- \r
- \r
- command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb) and field_serial != 3;";\r
- command.Parameters.Clear();\r
- command.ExecuteNonQuery();\r
- \r
- \r
- Assertion.AssertEquals(7.4M, result);\r
- \r
- \r
- \r
- \r
- }\r
- \r
- [Test]\r
- public void NegativeNumericSupport()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("select * from tableb where field_serial = 4", _conn);\r
- \r
- \r
- NpgsqlDataReader dr = command.ExecuteReader();\r
- dr.Read();\r
- \r
- Decimal result = dr.GetDecimal(3);\r
- \r
- Assertion.AssertEquals(-4.3M, result);\r
- \r
- }\r
- \r
- [Test]\r
- public void PrecisionScaleNumericSupport()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("select * from tableb where field_serial = 4", _conn);\r
- \r
- \r
- NpgsqlDataReader dr = command.ExecuteReader();\r
- dr.Read();\r
- \r
- Decimal result = dr.GetDecimal(3);\r
- \r
- Assertion.AssertEquals(-4.3M, (Decimal)result);\r
- //Assertion.AssertEquals(11, result.Precision);\r
- //Assertion.AssertEquals(7, result.Scale);\r
- \r
- }\r
- \r
- [Test]\r
- public void InsertNullString()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_text) values (:a)", _conn);\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.String));\r
- \r
- command.Parameters[0].Value = DBNull.Value;\r
- \r
- Int32 rowsAdded = command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(1, rowsAdded);\r
- \r
- command.CommandText = "select count(*) from tablea where field_text is null";\r
- command.Parameters.Clear();\r
- \r
- Int64 result = (Int64)command.ExecuteScalar();\r
- \r
- command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea) and field_serial != 4;";\r
- command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(4, result);\r
- \r
- \r
- \r
- }\r
- \r
- [Test]\r
- public void InsertNullDateTime()\r
- {\r
- _conn.Open();\r
- \r
- NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_timestamp) values (:a)", _conn);\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.DateTime));\r
- \r
- command.Parameters[0].Value = DBNull.Value;\r
- \r
- Int32 rowsAdded = command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(1, rowsAdded);\r
- \r
- command.CommandText = "select count(*) from tableb where field_timestamp is null";\r
- command.Parameters.Clear();\r
- \r
- Object result = command.ExecuteScalar();\r
- \r
- command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb) and field_serial != 3;";\r
- command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(4, result);\r
- \r
- \r
- \r
- }\r
- \r
- \r
- [Test]\r
- public void InsertNullInt16()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_int2) values (:a)", _conn);\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Int16));\r
- \r
- command.Parameters[0].Value = DBNull.Value;\r
- \r
- Int32 rowsAdded = command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(1, rowsAdded);\r
- \r
- command.CommandText = "select count(*) from tableb where field_int2 is null";\r
- command.Parameters.Clear();\r
- \r
- Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64\r
- \r
- command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb);";\r
- command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(4, result);\r
- \r
- \r
- }\r
- \r
- \r
- [Test]\r
- public void InsertNullInt32()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_int4) values (:a)", _conn);\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));\r
- \r
- command.Parameters[0].Value = DBNull.Value;\r
- \r
- Int32 rowsAdded = command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(1, rowsAdded);\r
- \r
- command.CommandText = "select count(*) from tablea where field_int4 is null";\r
- command.Parameters.Clear();\r
- \r
- Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64\r
- \r
- command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea);";\r
- command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(5, result);\r
- \r
- }\r
- \r
- \r
- [Test]\r
- public void InsertNullNumeric()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_numeric) values (:a)", _conn);\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Decimal));\r
- \r
- command.Parameters[0].Value = DBNull.Value;\r
- \r
- Int32 rowsAdded = command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(1, rowsAdded);\r
- \r
- command.CommandText = "select count(*) from tableb where field_numeric is null";\r
- command.Parameters.Clear();\r
- \r
- Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64\r
- \r
- command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb);";\r
- command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(3, result);\r
- \r
- }\r
- \r
- [Test]\r
- public void InsertNullBoolean()\r
- {\r
- _conn.Open();\r
- \r
- \r
- NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_bool) values (:a)", _conn);\r
- \r
- command.Parameters.Add(new NpgsqlParameter("a", DbType.Boolean));\r
- \r
- command.Parameters[0].Value = DBNull.Value;\r
- \r
- Int32 rowsAdded = command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(1, rowsAdded);\r
- \r
- command.CommandText = "select count(*) from tablea where field_bool is null";\r
- command.Parameters.Clear();\r
- \r
- Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64\r
- \r
- command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea);";\r
- command.ExecuteNonQuery();\r
- \r
- Assertion.AssertEquals(5, result);\r
- \r
- }\r
- \r
- \r
- \r
- \r
- }\r
-}\r
+// created on 30/11/2002 at 22:35
+//
+// Author:
+// Francisco Figueiredo Jr. <fxjrlists@yahoo.com>
+//
+// Copyright (C) 2002 The Npgsql Development Team
+// npgsql-general@gborg.postgresql.org
+// http://gborg.postgresql.org/project/npgsql/projdisplay.php
+//
+// 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 Npgsql;
+using NUnit.Framework;
+using NUnit.Core;
+using System.Data;
+using System.Globalization;
+using NpgsqlTypes;
+
+
+namespace NpgsqlTests
+{
+ [TestFixture]
+ public class CommandTests
+ {
+ NpgsqlConnection _conn = null;
+
+ [SetUp]
+ protected void SetUp()
+ {
+ //NpgsqlEventLog.Level = LogLevel.None;
+ //NpgsqlEventLog.Level = LogLevel.Debug;
+ //NpgsqlEventLog.LogName = "NpgsqlTests.LogFile";
+ _conn = new NpgsqlConnection (TestConfiguration.NpgsqlConnectionString);
+ }
+
+ [TearDown]
+ protected void TearDown()
+ {
+ if (_conn != null && _conn.State != ConnectionState.Closed)
+ _conn.Close();
+ }
+
+
+ [Test]
+ public void ParametersGetName()
+ {
+ NpgsqlCommand command = new NpgsqlCommand();
+
+ // Add parameters.
+ command.Parameters.Add(new NpgsqlParameter(":Parameter1", DbType.Boolean));
+ command.Parameters.Add(new NpgsqlParameter(":Parameter2", DbType.Int32));
+ command.Parameters.Add(new NpgsqlParameter(":Parameter3", DbType.DateTime));
+
+
+ // Get by indexers.
+
+ Assert.AreEqual(":Parameter1", command.Parameters[":Parameter1"].ParameterName);
+ Assert.AreEqual(":Parameter2", command.Parameters[":Parameter2"].ParameterName);
+ Assert.AreEqual(":Parameter3", command.Parameters[":Parameter3"].ParameterName);
+
+
+ Assert.AreEqual(":Parameter1", command.Parameters[0].ParameterName);
+ Assert.AreEqual(":Parameter2", command.Parameters[1].ParameterName);
+ Assert.AreEqual(":Parameter3", command.Parameters[2].ParameterName);
+
+
+
+ }
+
+ [Test]
+ public void EmptyQuery()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand(";", _conn);
+ command.ExecuteNonQuery();
+
+ }
+ [Test]
+ [ExpectedException(typeof(ArgumentNullException))]
+ public void NoNameParameterAdd()
+ {
+ NpgsqlCommand command = new NpgsqlCommand();
+
+ command.Parameters.Add(new NpgsqlParameter());
+
+ }
+
+ [Test]
+ public void FunctionCallFromSelect()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from funcB()", _conn);
+
+ NpgsqlDataReader reader = command.ExecuteReader();
+
+ Assertion.AssertNotNull(reader);
+ //reader.FieldCount
+
+ }
+
+ [Test]
+ public void ExecuteScalar()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select count(*) from tablea", _conn);
+
+ Object result = command.ExecuteScalar();
+
+ Assert.AreEqual(5, result);
+ //reader.FieldCount
+
+ }
+
+ [Test]
+ public void FunctionCallReturnSingleValue()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("funcC()", _conn);
+ command.CommandType = CommandType.StoredProcedure;
+
+ Object result = command.ExecuteScalar();
+
+ Assert.AreEqual(5, result);
+ //reader.FieldCount
+
+ }
+
+
+ [Test]
+ public void FunctionCallReturnSingleValueWithPrepare()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("funcC()", _conn);
+ command.CommandType = CommandType.StoredProcedure;
+
+ command.Prepare();
+ Object result = command.ExecuteScalar();
+
+ Assert.AreEqual(5, result);
+ //reader.FieldCount
+
+ }
+
+ [Test]
+ public void FunctionCallWithParametersReturnSingleValue()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("funcC(:a)", _conn);
+ command.CommandType = CommandType.StoredProcedure;
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));
+
+ command.Parameters[0].Value = 4;
+
+ Int64 result = (Int64) command.ExecuteScalar();
+
+ Assert.AreEqual(1, result);
+
+
+ }
+
+ [Test]
+ public void FunctionCallWithParametersReturnSingleValueNpgsqlDbType()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("funcC(:a)", _conn);
+ command.CommandType = CommandType.StoredProcedure;
+
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Integer));
+
+ command.Parameters[0].Value = 4;
+
+ Int64 result = (Int64) command.ExecuteScalar();
+
+ Assert.AreEqual(1, result);
+
+ }
+
+
+
+
+ [Test]
+ public void FunctionCallWithParametersPrepareReturnSingleValue()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("funcC(:a)", _conn);
+ command.CommandType = CommandType.StoredProcedure;
+
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));
+
+ Assert.AreEqual(1, command.Parameters.Count);
+ command.Prepare();
+
+
+ command.Parameters[0].Value = 4;
+
+ Int64 result = (Int64) command.ExecuteScalar();
+
+ Assert.AreEqual(1, result);
+
+
+ }
+
+ [Test]
+ public void FunctionCallWithParametersPrepareReturnSingleValueNpgsqlDbType()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("funcC(:a)", _conn);
+ command.CommandType = CommandType.StoredProcedure;
+
+
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Integer));
+
+ Assert.AreEqual(1, command.Parameters.Count);
+ command.Prepare();
+
+
+ command.Parameters[0].Value = 4;
+
+ Int64 result = (Int64) command.ExecuteScalar();
+
+ Assert.AreEqual(1, result);
+
+
+ }
+
+
+ [Test]
+ public void FunctionCallReturnResultSet()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("funcB()", _conn);
+ command.CommandType = CommandType.StoredProcedure;
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+
+
+
+
+ }
+
+
+ [Test]
+ public void CursorStatement()
+ {
+
+ _conn.Open();
+
+ Int32 i = 0;
+
+ NpgsqlTransaction t = _conn.BeginTransaction();
+
+ NpgsqlCommand command = new NpgsqlCommand("declare te cursor for select * from tablea;", _conn);
+
+ command.ExecuteNonQuery();
+
+ command.CommandText = "fetch forward 3 in te;";
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+
+
+ while (dr.Read())
+ {
+ i++;
+ }
+
+ Assert.AreEqual(3, i);
+
+
+ i = 0;
+
+ command.CommandText = "fetch backward 1 in te;";
+
+ NpgsqlDataReader dr2 = command.ExecuteReader();
+
+ while (dr2.Read())
+ {
+ i++;
+ }
+
+ Assert.AreEqual(1, i);
+
+ command.CommandText = "close te;";
+
+ command.ExecuteNonQuery();
+
+ t.Commit();
+
+
+
+ }
+
+ [Test]
+ public void PreparedStatementNoParameters()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from tablea;", _conn);
+
+ command.Prepare();
+
+ command.Prepare();
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+
+
+ }
+
+ [Test]
+ public void PreparedStatementWithParameters()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from tablea where field_int4 = :a and field_int8 = :b;", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));
+ command.Parameters.Add(new NpgsqlParameter("b", DbType.Int64));
+
+ Assert.AreEqual(2, command.Parameters.Count);
+
+ Assert.AreEqual(DbType.Int32, command.Parameters[0].DbType);
+
+ command.Prepare();
+
+ command.Parameters[0].Value = 3;
+ command.Parameters[1].Value = 5;
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+
+
+
+
+ }
+
+ [Test]
+ public void PreparedStatementWithParametersNpgsqlDbType()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from tablea where field_int4 = :a and field_int8 = :b;", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Integer));
+ command.Parameters.Add(new NpgsqlParameter("b", NpgsqlDbType.Bigint));
+
+ Assert.AreEqual(2, command.Parameters.Count);
+
+ Assert.AreEqual(DbType.Int32, command.Parameters[0].DbType);
+
+ command.Prepare();
+
+ command.Parameters[0].Value = 3;
+ command.Parameters[1].Value = 5;
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+
+
+
+
+ }
+
+
+ [Test]
+ [ExpectedException(typeof(InvalidOperationException))]
+ public void ListenNotifySupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("listen notifytest;", _conn);
+ command.ExecuteNonQuery();
+
+ _conn.Notification += new NotificationEventHandler(NotificationSupportHelper);
+
+
+ command = new NpgsqlCommand("notify notifytest;", _conn);
+ command.ExecuteNonQuery();
+
+
+
+ }
+
+ private void NotificationSupportHelper(Object sender, NpgsqlNotificationEventArgs args)
+ {
+ throw new InvalidOperationException();
+ }
+
+ [Test]
+ public void DateTimeSupport()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_timestamp from tableb where field_serial = 2;", _conn);
+
+ DateTime d = (DateTime)command.ExecuteScalar();
+
+
+ Assert.AreEqual("2002-02-02 09:00:23Z", d.ToString("u"));
+
+ DateTimeFormatInfo culture = new DateTimeFormatInfo();
+ culture.TimeSeparator = ":";
+ DateTime dt = System.DateTime.Parse("2004-06-04 09:48:00", culture);
+
+ command.CommandText = "insert into tableb(field_timestamp) values (:a);delete from tableb where field_serial > 4;";
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.DateTime));
+ command.Parameters[0].Value = dt;
+
+ command.ExecuteScalar();
+
+ }
+
+
+ [Test]
+ public void DateTimeSupportNpgsqlDbType()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_timestamp from tableb where field_serial = 2;", _conn);
+
+ DateTime d = (DateTime)command.ExecuteScalar();
+
+
+ Assert.AreEqual("2002-02-02 09:00:23Z", d.ToString("u"));
+
+ DateTimeFormatInfo culture = new DateTimeFormatInfo();
+ culture.TimeSeparator = ":";
+ DateTime dt = System.DateTime.Parse("2004-06-04 09:48:00", culture);
+
+ command.CommandText = "insert into tableb(field_timestamp) values (:a);delete from tableb where field_serial > 4;";
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Timestamp));
+ command.Parameters[0].Value = dt;
+
+ command.ExecuteScalar();
+
+ }
+
+ [Test]
+ public void DateSupport()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_date from tablec where field_serial = 1;", _conn);
+
+ DateTime d = (DateTime)command.ExecuteScalar();
+
+
+ Assert.AreEqual("2002-03-04", d.ToString("yyyy-MM-dd"));
+
+ }
+
+ [Test]
+ public void TimeSupport()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_time from tablec where field_serial = 2;", _conn);
+
+ DateTime d = (DateTime)command.ExecuteScalar();
+
+
+ Assert.AreEqual("10:03:45.345", d.ToString("HH:mm:ss.fff"));
+
+ }
+
+ [Test]
+ public void NumericSupport()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_numeric) values (:a)", _conn);
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Decimal));
+
+ command.Parameters[0].Value = 7.4M;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select * from tableb where field_numeric = :a";
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Decimal result = dr.GetDecimal(3);
+
+
+ command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb) and field_serial != 3;";
+ command.Parameters.Clear();
+ command.ExecuteNonQuery();
+
+
+ Assert.AreEqual(7.4000000M, result);
+
+
+
+
+ }
+
+ [Test]
+ public void NumericSupportNpgsqlDbType()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_numeric) values (:a)", _conn);
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Numeric));
+
+ command.Parameters[0].Value = 7.4M;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select * from tableb where field_numeric = :a";
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Decimal result = dr.GetDecimal(3);
+
+
+ command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb) and field_serial != 3;";
+ command.Parameters.Clear();
+ command.ExecuteNonQuery();
+
+
+ Assert.AreEqual(7.4000000M, result);
+
+
+
+
+ }
+
+
+ [Test]
+ public void InsertSingleValue()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tabled(field_float4) values (:a)", _conn);
+ command.Parameters.Add(new NpgsqlParameter(":a", DbType.Single));
+
+ command.Parameters[0].Value = 7.4F;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select * from tabled where field_float4 = :a";
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Single result = dr.GetFloat(1);
+
+
+ command.CommandText = "delete from tabled where field_serial > 2;";
+ command.Parameters.Clear();
+ command.ExecuteNonQuery();
+
+
+ Assert.AreEqual(7.4F, result);
+
+ }
+
+
+ [Test]
+ public void InsertSingleValueNpgsqlDbType()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tabled(field_float4) values (:a)", _conn);
+ command.Parameters.Add(new NpgsqlParameter(":a", NpgsqlDbType.Real));
+
+ command.Parameters[0].Value = 7.4F;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select * from tabled where field_float4 = :a";
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Single result = dr.GetFloat(1);
+
+
+ command.CommandText = "delete from tabled where field_serial > 2;";
+ command.Parameters.Clear();
+ command.ExecuteNonQuery();
+
+
+ Assert.AreEqual(7.4F, result);
+
+ }
+
+ [Test]
+ public void InsertDoubleValue()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tabled(field_float8) values (:a)", _conn);
+ command.Parameters.Add(new NpgsqlParameter(":a", DbType.Double));
+
+ command.Parameters[0].Value = 7.4D;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select * from tabled where field_float8 = :a";
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Double result = dr.GetDouble(2);
+
+
+ command.CommandText = "delete from tabled where field_serial > 2;";
+ command.Parameters.Clear();
+ //command.ExecuteNonQuery();
+
+
+ Assert.AreEqual(7.4D, result);
+
+ }
+
+
+ [Test]
+ public void InsertDoubleValueNpgsqlDbType()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tabled(field_float8) values (:a)", _conn);
+ command.Parameters.Add(new NpgsqlParameter(":a", NpgsqlDbType.Double));
+
+ command.Parameters[0].Value = 7.4D;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select * from tabled where field_float8 = :a";
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Double result = dr.GetDouble(2);
+
+
+ command.CommandText = "delete from tabled where field_serial > 2;";
+ command.Parameters.Clear();
+ //command.ExecuteNonQuery();
+
+
+ Assert.AreEqual(7.4D, result);
+
+ }
+
+
+ [Test]
+ public void NegativeNumericSupport()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from tableb where field_serial = 4", _conn);
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Decimal result = dr.GetDecimal(3);
+
+ Assert.AreEqual(-4.3000000M, result);
+
+ }
+
+
+ [Test]
+ public void PrecisionScaleNumericSupport()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from tableb where field_serial = 4", _conn);
+
+
+ NpgsqlDataReader dr = command.ExecuteReader();
+ dr.Read();
+
+ Decimal result = dr.GetDecimal(3);
+
+ Assert.AreEqual(-4.3000000M, (Decimal)result);
+ //Assert.AreEqual(11, result.Precision);
+ //Assert.AreEqual(7, result.Scale);
+
+ }
+
+ [Test]
+ public void InsertNullString()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_text) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.String));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tablea where field_text is null";
+ command.Parameters.Clear();
+
+ Int64 result = (Int64)command.ExecuteScalar();
+
+ command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea) and field_serial != 4;";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(4, result);
+
+
+
+ }
+
+ [Test]
+ public void InsertNullStringNpgsqlDbType()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_text) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Text));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tablea where field_text is null";
+ command.Parameters.Clear();
+
+ Int64 result = (Int64)command.ExecuteScalar();
+
+ command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea) and field_serial != 4;";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(4, result);
+
+
+
+ }
+
+
+
+ [Test]
+ public void InsertNullDateTime()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_timestamp) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.DateTime));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tableb where field_timestamp is null";
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar();
+
+ command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb) and field_serial != 3;";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(4, result);
+
+
+
+ }
+
+
+ [Test]
+ public void InsertNullDateTimeNpgsqlDbType()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_timestamp) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Timestamp));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tableb where field_timestamp is null";
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar();
+
+ command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb) and field_serial != 3;";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(4, result);
+
+
+
+ }
+
+
+
+ [Test]
+ public void InsertNullInt16()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_int2) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Int16));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tableb where field_int2 is null";
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64
+
+ command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb);";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(4, result);
+
+
+ }
+
+
+ [Test]
+ public void InsertNullInt16NpgsqlDbType()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_int2) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", NpgsqlDbType.Smallint));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tableb where field_int2 is null";
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64
+
+ command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb);";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(4, result);
+
+
+ }
+
+
+ [Test]
+ public void InsertNullInt32()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_int4) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tablea where field_int4 is null";
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64
+
+ command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea);";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(5, result);
+
+ }
+
+
+ [Test]
+ public void InsertNullNumeric()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tableb(field_numeric) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Decimal));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tableb where field_numeric is null";
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64
+
+ command.CommandText = "delete from tableb where field_serial = (select max(field_serial) from tableb);";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(3, result);
+
+ }
+
+ [Test]
+ public void InsertNullBoolean()
+ {
+ _conn.Open();
+
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_bool) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Boolean));
+
+ command.Parameters[0].Value = DBNull.Value;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = "select count(*) from tablea where field_bool is null";
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64
+
+ command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea);";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(5, result);
+
+ }
+
+ [Test]
+ public void AnsiStringSupport()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_text) values (:a)", _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.AnsiString));
+
+ command.Parameters[0].Value = "TesteAnsiString";
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, rowsAdded);
+
+ command.CommandText = String.Format("select count(*) from tablea where field_text = '{0}'", command.Parameters[0].Value);
+ command.Parameters.Clear();
+
+ Object result = command.ExecuteScalar(); // The missed cast is needed as Server7.2 returns Int32 and Server7.3+ returns Int64
+
+ command.CommandText = "delete from tablea where field_serial = (select max(field_serial) from tablea);";
+ command.ExecuteNonQuery();
+
+ Assert.AreEqual(1, result);
+
+ }
+
+
+ [Test]
+ public void MultipleQueriesFirstResultsetEmpty()
+ {
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("insert into tablea(field_text) values ('a'); select count(*) from tablea;", _conn);
+
+ Object result = command.ExecuteScalar();
+
+
+ command.CommandText = "delete from tablea where field_serial > 5";
+ command.ExecuteNonQuery();
+
+ command.CommandText = "select * from tablea where field_serial = 0";
+ command.ExecuteScalar();
+
+
+ Assert.AreEqual(6, result);
+
+
+ }
+
+ [Test]
+ [ExpectedException(typeof(NpgsqlException))]
+ public void ConnectionStringWithInvalidParameters()
+ {
+ NpgsqlConnection conn = new NpgsqlConnection("Server=127.0.0.1;User Id=npgsql_tests;Password=j");
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from tablea", conn);
+
+ command.Connection.Open();
+ command.ExecuteReader();
+ command.Connection.Close();
+
+
+ }
+
+ [Test]
+ [ExpectedException(typeof(NpgsqlException))]
+ public void InvalidConnectionString()
+ {
+ NpgsqlConnection conn = new NpgsqlConnection("Server=127.0.0.1;User Id=npgsql_tests");
+
+ NpgsqlCommand command = new NpgsqlCommand("select * from tablea", conn);
+
+ command.Connection.Open();
+ command.ExecuteReader();
+ command.Connection.Close();
+
+
+ }
+
+
+ [Test]
+ public void AmbiguousFunctionParameterType()
+ {
+ NpgsqlConnection conn = new NpgsqlConnection("Server=127.0.0.1;User Id=npgsql_tests;Password=npgsql_tests");
+
+
+ NpgsqlCommand command = new NpgsqlCommand("ambiguousParameterType(:a, :b, :c, :d, :e, :f)", conn);
+ command.CommandType = CommandType.StoredProcedure;
+ NpgsqlParameter p = new NpgsqlParameter("a", DbType.Int16);
+ p.Value = 2;
+ command.Parameters.Add(p);
+ p = new NpgsqlParameter("b", DbType.Int32);
+ p.Value = 2;
+ command.Parameters.Add(p);
+ p = new NpgsqlParameter("c", DbType.Int64);
+ p.Value = 2;
+ command.Parameters.Add(p);
+ p = new NpgsqlParameter("d", DbType.String);
+ p.Value = "a";
+ command.Parameters.Add(p);
+ p = new NpgsqlParameter("e", DbType.String);
+ p.Value = "a";
+ command.Parameters.Add(p);
+ p = new NpgsqlParameter("f", DbType.String);
+ p.Value = "a";
+ command.Parameters.Add(p);
+
+
+ command.Connection.Open();
+ command.Prepare();
+ command.ExecuteScalar();
+ command.Connection.Close();
+
+
+ }
+
+
+ [Test]
+ public void TestParameterReplace()
+ {
+ _conn.Open();
+
+ String sql = @"select * from tablea where
+ field_serial = :a
+ ";
+
+
+ NpgsqlCommand command = new NpgsqlCommand(sql, _conn);
+
+ command.Parameters.Add(new NpgsqlParameter("a", DbType.Int32));
+
+ command.Parameters[0].Value = 2;
+
+ Int32 rowsAdded = command.ExecuteNonQuery();
+
+ }
+
+ [Test]
+ public void TestPointSupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_point from tablee where field_serial = 1", _conn);
+
+ NpgsqlPoint p = (NpgsqlPoint) command.ExecuteScalar();
+
+ Assert.AreEqual(4, p.X);
+ Assert.AreEqual(3, p.Y);
+ }
+
+
+ [Test]
+ public void TestBoxSupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_box from tablee where field_serial = 2", _conn);
+
+ NpgsqlBox box = (NpgsqlBox) command.ExecuteScalar();
+
+ Assert.AreEqual(5, box.UpperRight.X);
+ Assert.AreEqual(4, box.UpperRight.Y);
+ Assert.AreEqual(4, box.LowerLeft.X);
+ Assert.AreEqual(3, box.LowerLeft.Y);
+
+
+ }
+
+ [Test]
+ public void TestLSegSupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_lseg from tablee where field_serial = 3", _conn);
+
+ NpgsqlLSeg lseg = (NpgsqlLSeg) command.ExecuteScalar();
+
+ Assert.AreEqual(4, lseg.Start.X);
+ Assert.AreEqual(3, lseg.Start.Y);
+ Assert.AreEqual(5, lseg.End.X);
+ Assert.AreEqual(4, lseg.End.Y);
+
+
+ }
+
+ [Test]
+ public void TestClosedPathSupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_path from tablee where field_serial = 4", _conn);
+
+ NpgsqlPath path = (NpgsqlPath) command.ExecuteScalar();
+
+ Assert.AreEqual(false, path.Open);
+ Assert.AreEqual(2, path.Count);
+ Assert.AreEqual(4, path[0].X);
+ Assert.AreEqual(3, path[0].Y);
+ Assert.AreEqual(5, path[1].X);
+ Assert.AreEqual(4, path[1].Y);
+
+
+ }
+
+ [Test]
+ public void TestOpenPathSupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_path from tablee where field_serial = 5", _conn);
+
+ NpgsqlPath path = (NpgsqlPath) command.ExecuteScalar();
+
+ Assert.AreEqual(true, path.Open);
+ Assert.AreEqual(2, path.Count);
+ Assert.AreEqual(4, path[0].X);
+ Assert.AreEqual(3, path[0].Y);
+ Assert.AreEqual(5, path[1].X);
+ Assert.AreEqual(4, path[1].Y);
+
+
+ }
+
+
+
+ [Test]
+ public void TestPolygonSupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_polygon from tablee where field_serial = 6", _conn);
+
+ NpgsqlPolygon polygon = (NpgsqlPolygon) command.ExecuteScalar();
+
+ Assert.AreEqual(2, polygon.Count);
+ Assert.AreEqual(4, polygon[0].X);
+ Assert.AreEqual(3, polygon[0].Y);
+ Assert.AreEqual(5, polygon[1].X);
+ Assert.AreEqual(4, polygon[1].Y);
+
+
+ }
+
+
+ [Test]
+ public void TestCircleSupport()
+ {
+
+ _conn.Open();
+
+ NpgsqlCommand command = new NpgsqlCommand("select field_circle from tablee where field_serial = 7", _conn);
+
+ NpgsqlCircle circle = (NpgsqlCircle) command.ExecuteScalar();
+
+ Assert.AreEqual(4, circle.Center.X);
+ Assert.AreEqual(3, circle.Center.Y);
+ Assert.AreEqual(5, circle.Radius);
+
+
+
+ }
+
+
+
+
+
+
+ }
+}
projects / mono.git / blobdiff