// 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);
			
			
			
		}
		
		
		
		
		
		
	}
}