pgsqlclient-checkins — Mailing list for CVS commit messages.

[pgsqlclient-checkins] pgsqlclient changelog.txt,1.3,1.4

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient
In directory sc8-pr-cvs1:/tmp/cvs-serv26686

Modified Files:
	changelog.txt 
Log Message:
Updated CHANGELOG.TXT

Index: changelog.txt
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/changelog.txt,v
retrieving revision 1.3
retrieving revision 1.4
diff -C2 -d -r1.3 -r1.4
*** changelog.txt	13 Jul 2003 11:41:34 -0000	1.3
--- changelog.txt	13 Jul 2003 13:44:17 -0000	1.4
***************
*** 11,14 ****
--- 11,22 ----
  		- Fixed implementation of GetSchemaTable method.
  
+ 	* source/PGCommand.cs:
+ 
+ 		- Added better handling of exceptions and command parameters.
+ 
+ 	* source/PGException.cs:
+ 
+ 		- Fixed constructors.
+ 
  
  2003-07-12 Carlos Guzmán Álvarez  <car...@te...>

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient/source PGException.cs,1.1.1.1,1.2

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source
In directory sc8-pr-cvs1:/tmp/cvs-serv26608

Modified Files:
	PGException.cs 
Log Message:
Fixed constructors

Index: PGException.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source/PGException.cs,v
retrieving revision 1.1.1.1
retrieving revision 1.2
diff -C2 -d -r1.1.1.1 -r1.2
*** PGException.cs	12 Jul 2003 08:11:21 -0000	1.1.1.1
--- PGException.cs	13 Jul 2003 13:43:46 -0000	1.2
***************
*** 38,45 ****
  		public new string Message
  		{
! 			get 
! 			{ 
! 				return message; 
! 			}
  		}
  
--- 38,42 ----
  		public new string Message
  		{
! 			get { return this.message; }
  		}
  
***************
*** 52,69 ****
  
  		#region CONSTRUCTORS
! 
  		internal PGException() : base()
  		{
  			errors = new PGErrorCollection();
  		}
! 		
! 		internal PGException(string message) : this()
  		{
! 			this.message = message;
  		}
  
! 		internal PGException(string message, PGClientException ex) : this()
  		{
! 			this.message = message;
  			getPGExceptionErrors(ex);
  		}
--- 49,74 ----
  
  		#region CONSTRUCTORS
! 		
  		internal PGException() : base()
  		{
  			errors = new PGErrorCollection();
  		}
! 
! 		internal PGException(string message) : base(message)
  		{
! 			errors = new PGErrorCollection();
  		}
  
! 		internal PGException(SerializationInfo info, StreamingContext context) : base(info, context)
  		{
! 			errors = new PGErrorCollection();
! 		}
! 		
! 		internal PGException(string message, PGClientException ex) : base(message, ex)
! 		{
! 			errors		= new PGErrorCollection();
! 			errorCode	= ex.ErrorCode;
! 			Source		= ex.Source;
! 
  			getPGExceptionErrors(ex);
  		}

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient/source PGDataReader.cs,1.2,1.3

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source
In directory sc8-pr-cvs1:/tmp/cvs-serv26373

Modified Files:
	PGDataReader.cs 
Log Message:
Minor change

Index: PGDataReader.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source/PGDataReader.cs,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** PGDataReader.cs	13 Jul 2003 11:41:12 -0000	1.2
--- PGDataReader.cs	13 Jul 2003 13:41:25 -0000	1.3
***************
*** 182,187 ****
  			bool read = true;
  
! 			if (command.CommandBehavior == CommandBehavior.SingleRow && 
! 				position != STARTPOS)
  			{
  				read = false;
--- 182,186 ----
  			bool read = true;
  
! 			if (command.CommandBehavior == CommandBehavior.SingleRow && position != STARTPOS)
  			{
  				read = false;

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient/source PGCommand.cs,1.1.1.1,1.2

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source
In directory sc8-pr-cvs1:/tmp/cvs-serv26079

Modified Files:
	PGCommand.cs 
Log Message:
Added better handling of exceptions and command parameters.

Index: PGCommand.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source/PGCommand.cs,v
retrieving revision 1.1.1.1
retrieving revision 1.2
diff -C2 -d -r1.1.1.1 -r1.2
*** PGCommand.cs	12 Jul 2003 08:11:20 -0000	1.1.1.1
--- PGCommand.cs	13 Jul 2003 13:39:00 -0000	1.2
***************
*** 306,318 ****
  			}
  
! 			try
! 			{
! 				InternalPrepare();
! 				InternalExecute();
! 			}
! 			catch (PGClientException ex)
! 			{
! 					throw new PGException(ex.Message, ex);
! 			}
  			
  			return statement.RecordsAffected;
--- 306,311 ----
  			}
  
! 			InternalPrepare();
! 			InternalExecute();
  			
  			return statement.RecordsAffected;
***************
*** 354,375 ****
  			}
  
! 			try
! 			{
! 				commandBehavior = behavior;				
  
! 				InternalPrepare();
  
! 				if ((commandBehavior & System.Data.CommandBehavior.SequentialAccess) == System.Data.CommandBehavior.SequentialAccess ||
! 					(commandBehavior & System.Data.CommandBehavior.SingleResult) == System.Data.CommandBehavior.SingleResult ||
! 					(commandBehavior & System.Data.CommandBehavior.SingleRow) == System.Data.CommandBehavior.SingleRow ||
! 					(commandBehavior & System.Data.CommandBehavior.CloseConnection) == System.Data.CommandBehavior.CloseConnection ||
! 					commandBehavior == System.Data.CommandBehavior.Default)				
! 				{
! 					InternalExecute();
! 				}
! 			}
! 			catch (PGClientException ex)
  			{
! 				throw new PGException(ex.Message, ex);
  			}
  
--- 347,361 ----
  			}
  
! 			commandBehavior = behavior;
  
! 			InternalPrepare();
  
! 			if ((commandBehavior & System.Data.CommandBehavior.SequentialAccess) == System.Data.CommandBehavior.SequentialAccess ||
! 				(commandBehavior & System.Data.CommandBehavior.SingleResult) == System.Data.CommandBehavior.SingleResult ||
! 				(commandBehavior & System.Data.CommandBehavior.SingleRow) == System.Data.CommandBehavior.SingleRow ||
! 				(commandBehavior & System.Data.CommandBehavior.CloseConnection) == System.Data.CommandBehavior.CloseConnection ||
! 				commandBehavior == System.Data.CommandBehavior.Default)				
  			{
! 				InternalExecute();
  			}
  
***************
*** 399,415 ****
  			object returnValue = null;
  
! 			try
! 			{
! 				InternalPrepare();				
! 				InternalExecute();
  
! 				if (statement.HasRows)
! 				{
! 					returnValue = ((object[])statement.Rows[0])[0];
! 				}
! 			}
! 			catch (PGClientException ex)
  			{
! 				throw new PGException(ex.Message, ex);
  			}
  
--- 385,394 ----
  			object returnValue = null;
  
! 			InternalPrepare();				
! 			InternalExecute();
  
! 			if (statement.HasRows)
  			{
! 				returnValue = ((object[])statement.Rows[0])[0];
  			}
  
***************
*** 432,445 ****
  			}
  
! 			try
! 			{
! 				InternalPrepare();
! 
! 				connection.ActiveCommands.Add(this);
! 			}
! 			catch (PGClientException ex)
! 			{
! 				throw new PGException(ex.Message, ex);
! 			}
  		}
  
--- 411,416 ----
  			}
  
! 			InternalPrepare();
! 			connection.ActiveCommands.Add(this);
  		}
  
***************
*** 447,459 ****
  		{
  			string plan;
! 			if (statement == null)
  			{
! 				statement = connection.DbConnection.DB.CreateStatement(commandText);
! 				plan = statement.GetPlan(verbose);
! 				statement = null;
  			}
! 			else
  			{
! 				plan = statement.GetPlan(verbose);
  			}
  
--- 418,438 ----
  		{
  			string plan;
! 
! 			try
  			{
! 				if (statement == null)
! 				{
! 					statement = connection.DbConnection.DB.CreateStatement(commandText);
! 					plan = statement.GetPlan(verbose);
! 					statement = null;
! 				}
! 				else
! 				{
! 					plan = statement.GetPlan(verbose);
! 				}
  			}
! 			catch (PGClientException ex)
  			{
! 				throw new PGException(ex.Message, ex);
  			}
  
***************
*** 472,480 ****
  					statement.Status == PGStatementStatus.Error)
  				{
! 					/* Get named parameters in CommandText	*/
! 					namedParameters = search.Matches(CommandText);
! 				
! 					/* Subst parameterNames	with $position */
! 					parseParameterNames();
  
  					string prepareName	= "PS" + getStmtName();
--- 451,461 ----
  					statement.Status == PGStatementStatus.Error)
  				{
! 					if (parameters.Count != 0)
! 					{
! 						// Get named parameters in CommandText
! 						namedParameters = search.Matches(CommandText);				
! 						// Subst parameterNames	with $position
! 						parseParameterNames();
! 					}
  
  					string prepareName	= "PS" + getStmtName();
***************
*** 497,501 ****
  			catch (PGClientException ex)
  			{
! 				throw ex;
  			}
  		}
--- 478,482 ----
  			catch (PGClientException ex)
  			{
! 				throw new PGException(ex.Message, ex);
  			}
  		}
***************
*** 505,510 ****
  			try
  			{
! 				// Set parameter values
! 				setParameterValues();
  
  				// Bind Statement
--- 486,494 ----
  			try
  			{
! 				if (parameters.Count != 0)
! 				{
! 					// Set parameter values
! 					setParameterValues();
! 				}
  
  				// Bind Statement
***************
*** 529,533 ****
  			catch (PGClientException ex)
  			{
! 				throw ex;
  			}
  		}
--- 513,517 ----
  			catch (PGClientException ex)
  			{
! 				throw new PGException(ex.Message, ex);
  			}
  		}

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source PGCommandTest.cs,1.1.1.1,1.2

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source
In directory sc8-pr-cvs1:/tmp/cvs-serv18807

Modified Files:
	PGCommandTest.cs 
Log Message:
Fixed incorrect update command text.

Index: PGCommandTest.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source/PGCommandTest.cs,v
retrieving revision 1.1.1.1
retrieving revision 1.2
diff -C2 -d -r1.1.1.1 -r1.2
*** PGCommandTest.cs	12 Jul 2003 08:11:23 -0000	1.1.1.1
--- PGCommandTest.cs	13 Jul 2003 12:39:30 -0000	1.2
***************
*** 32,36 ****
  			Console.WriteLine("\r\nPGCommandTest.ExecuteNonQueryTest");
  
! 			string commandText = "update public.test_table set char_field = @char_field and varchar_field = @varchar_field where int_field = @int_field";
  
  			PGTransaction transaction = Connection.BeginTransaction();
--- 32,36 ----
  			Console.WriteLine("\r\nPGCommandTest.ExecuteNonQueryTest");
  
! 			string commandText = "update public.test_table set char_field = @char_field, varchar_field = @varchar_field where int_field = @int_field";
  
  			PGTransaction transaction = Connection.BeginTransaction();

[pgsqlclient-checkins] pgsqlclient changelog.txt,1.2,1.3

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient
In directory sc8-pr-cvs1:/tmp/cvs-serv12497

Modified Files:
	changelog.txt 
Log Message:
Updated CHANGELOG.TXT

Index: changelog.txt
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/changelog.txt,v
retrieving revision 1.2
retrieving revision 1.3
diff -C2 -d -r1.2 -r1.3
*** changelog.txt	12 Jul 2003 21:36:44 -0000	1.2
--- changelog.txt	13 Jul 2003 11:41:34 -0000	1.3
***************
*** 3,6 ****
--- 3,15 ----
  
  
+ 2003-07-13 Carlos Guzmán Álvarez  <car...@te...>
+ 
+ 	* Added Test cases for PGDataReader and PGTransaction classes.
+ 
+ 	* source/PGDataReader.cs:
+ 
+ 		- Fixed implementation of GetSchemaTable method.
+ 
+ 
  2003-07-12 Carlos Guzmán Álvarez  <car...@te...>
  
***************
*** 8,16 ****
  	* Added changelog.txt file.
  
! 	* PostgreSql.Data.PGSqlClient/source/PGConnection.cs:
  
  		- Do not allow to execute CreateDatabase and GetDbSchemaTable if there are a DataReader open.
  
! 	* PostgreSql.Data.PGSqlClient/source/PGDbConnection.cs:
  
  		- Changed Regular expression used for parsing connection string.
--- 17,25 ----
  	* Added changelog.txt file.
  
! 	* source/PGConnection.cs:
  
  		- Do not allow to execute CreateDatabase and GetDbSchemaTable if there are a DataReader open.
  
! 	* source/PGDbConnection.cs:
  
  		- Changed Regular expression used for parsing connection string.

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient/source PGDataReader.cs,1.1.1.1,1.2

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source
In directory sc8-pr-cvs1:/tmp/cvs-serv12482

Modified Files:
	PGDataReader.cs 
Log Message:
Fixed implementation of GetSchemaTable method.

Index: PGDataReader.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source/PGDataReader.cs,v
retrieving revision 1.1.1.1
retrieving revision 1.2
diff -C2 -d -r1.1.1.1 -r1.2
*** PGDataReader.cs	12 Jul 2003 08:11:21 -0000	1.1.1.1
--- PGDataReader.cs	13 Jul 2003 11:41:12 -0000	1.2
***************
*** 250,270 ****
  					schemaRow["IsRowVersion"]		= false;
  					schemaRow["IsUnique"]			= false;
- 					schemaRow["IsKey"]				= isPrimaryKey(pKeyInfo, (short)columnInfo[7]);
  					schemaRow["IsAutoIncrement"]	= isAutoIncrement(i);
  					schemaRow["IsAliased"]			= isAliased(i);
  					schemaRow["IsExpression"]		= isExpression(i);
  					if (columnInfo != null)
  					{
! 						schemaRow["AllowDBNull"]		= columnInfo[10];
! 						schemaRow["BaseSchemaName"]		= columnInfo[1];
! 						schemaRow["BaseCatalogName"]	= columnInfo[0];
! 						schemaRow["BaseTableName"]		= columnInfo[2];
! 						schemaRow["BaseColumnName"]		= columnInfo[3];
  					}
  					else
  					{
! 						schemaRow["AllowDBNull"]		= System.DBNull.Value;
  						schemaRow["BaseSchemaName"]		= System.DBNull.Value;
- 						schemaRow["BaseCatalogName"]	= System.DBNull.Value;
  						schemaRow["BaseTableName"]		= System.DBNull.Value;
  						schemaRow["BaseColumnName"]		= System.DBNull.Value;
--- 250,270 ----
  					schemaRow["IsRowVersion"]		= false;
  					schemaRow["IsUnique"]			= false;
  					schemaRow["IsAutoIncrement"]	= isAutoIncrement(i);
  					schemaRow["IsAliased"]			= isAliased(i);
  					schemaRow["IsExpression"]		= isExpression(i);
+ 					schemaRow["BaseCatalogName"]	= System.DBNull.Value;
  					if (columnInfo != null)
  					{
! 						schemaRow["IsKey"]				= isPrimaryKey(pKeyInfo, (short)columnInfo[6]);
! 						schemaRow["AllowDBNull"]		= columnInfo[9];						
! 						schemaRow["BaseSchemaName"]		= columnInfo[0].ToString();						
! 						schemaRow["BaseTableName"]		= columnInfo[1].ToString();
! 						schemaRow["BaseColumnName"]		= columnInfo[2].ToString();
  					}
  					else
  					{
! 						schemaRow["IsKey"]				= false;
! 						schemaRow["AllowDBNull"]		= System.DBNull.Value;						
  						schemaRow["BaseSchemaName"]		= System.DBNull.Value;
  						schemaRow["BaseTableName"]		= System.DBNull.Value;
  						schemaRow["BaseColumnName"]		= System.DBNull.Value;
***************
*** 293,297 ****
  			schemaCmd.InternalExecute();
  
! 			if (schemaCmd.Statement.Rows[0] != null)
  			{
  				columnInfo = (object[])schemaCmd.Statement.Rows[0];
--- 293,297 ----
  			schemaCmd.InternalExecute();
  
! 			if (schemaCmd.Statement.Rows.Count > 0)
  			{
  				columnInfo = (object[])schemaCmd.Statement.Rows[0];
***************
*** 316,323 ****
  			schemaCmd.InternalExecute();
  
! 			if (schemaCmd.Statement.Rows[0] != null)
  			{
  				object[] temp = (object[])schemaCmd.Statement.Rows[0];
! 				columnInfo = (System.Array)temp[4];
  			}
  
--- 316,323 ----
  			schemaCmd.InternalExecute();
  
! 			if (schemaCmd.Statement.Rows.Count > 0)
  			{
  				object[] temp = (object[])schemaCmd.Statement.Rows[0];
! 				columnInfo = (System.Array)temp[3];
  			}
  
***************
*** 330,334 ****
  		private bool isPrimaryKey(System.Array pKeyInfo, short ordinal)
  		{
! 			for (int i = 0; i < pKeyInfo.Length; i++)
  			{
  				if ((short)pKeyInfo.GetValue(i) == ordinal)
--- 330,334 ----
  		private bool isPrimaryKey(System.Array pKeyInfo, short ordinal)
  		{
! 			for (int i = 1; i < pKeyInfo.Length; i++)
  			{
  				if ((short)pKeyInfo.GetValue(i) == ordinal)

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source PGTransactionTest.cs,NONE,1.1

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source
In directory sc8-pr-cvs1:/tmp/cvs-serv9258

Added Files:
	PGTransactionTest.cs 
Log Message:
Added Test case for PGTransaction class

--- NEW FILE: PGTransactionTest.cs ---
(This appears to be a binary file; contents omitted.)

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source PGDataReaderTest.cs,NONE,1.1

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient.UnitTests/source
In directory sc8-pr-cvs1:/tmp/cvs-serv9171

Added Files:
	PGDataReaderTest.cs 
Log Message:
Added Test case for PGDataReader class

--- NEW FILE: PGDataReaderTest.cs ---
(This appears to be a binary file; contents omitted.)

[pgsqlclient-checkins] pgsqlclient changelog.txt,1.1,1.2

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient
In directory sc8-pr-cvs1:/tmp/cvs-serv10252

Modified Files:
	changelog.txt 
Log Message:
Updated CHANGELOG.TXT

Index: changelog.txt
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/changelog.txt,v
retrieving revision 1.1
retrieving revision 1.2
diff -C2 -d -r1.1 -r1.2
*** changelog.txt	12 Jul 2003 13:58:39 -0000	1.1
--- changelog.txt	12 Jul 2003 21:36:44 -0000	1.2
***************
*** 12,15 ****
--- 12,19 ----
  		- Do not allow to execute CreateDatabase and GetDbSchemaTable if there are a DataReader open.
  
+ 	* PostgreSql.Data.PGSqlClient/source/PGDbConnection.cs:
+ 
+ 		- Changed Regular expression used for parsing connection string.
+ 
  
  2003-07-12 Carlos Guzmán Álvarez  <car...@te...>

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient/source PGDbConnection.cs,1.1.1.1,1.2

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source
In directory sc8-pr-cvs1:/tmp/cvs-serv10223

Modified Files:
	PGDbConnection.cs 
Log Message:
Changed Regular expression used for parsing connection string.

Index: PGDbConnection.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source/PGDbConnection.cs,v
retrieving revision 1.1.1.1
retrieving revision 1.2
diff -C2 -d -r1.1.1.1 -r1.2
*** PGDbConnection.cs	12 Jul 2003 08:11:21 -0000	1.1.1.1
--- PGDbConnection.cs	12 Jul 2003 21:36:27 -0000	1.2
***************
*** 81,85 ****
  		{
  			settings			= new PGConnectionParams();
! 			search				= new Regex(@"([\w\s\d]*)\s*=\s*([\w\s\d]*)");
  
  			connectionString	= String.Empty;
--- 81,86 ----
  		{
  			settings			= new PGConnectionParams();
! 			// search				= new Regex(@"([\w\s\d]*)\s*=\s*([\w\s\d]*)");
! 			search				= new Regex(@"([\w\s\d]*)\s*=\s*([^;]*)");
  
  			connectionString	= String.Empty;

[pgsqlclient-checkins] pgsqlclient changelog.txt,NONE,1.1

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient
In directory sc8-pr-cvs1:/tmp/cvs-serv8720

Added Files:
	changelog.txt 
Log Message:
Added changelog.txt file.

--- NEW FILE: changelog.txt ---
(This appears to be a binary file; contents omitted.)

[pgsqlclient-checkins] pgsqlclient/PostgreSql.Data.PGSqlClient/source PGConnection.cs,1.1.1.1,1.2

[<car...@us...>]

Update of /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source
In directory sc8-pr-cvs1:/tmp/cvs-serv8667

Modified Files:
	PGConnection.cs 
Log Message:
Do not allow to execute CreateDatabase and GetDbSchemaTable if there are a DataReader open.

Index: PGConnection.cs
===================================================================
RCS file: /cvsroot/pgsqlclient/pgsqlclient/PostgreSql.Data.PGSqlClient/source/PGConnection.cs,v
retrieving revision 1.1.1.1
retrieving revision 1.2
diff -C2 -d -r1.1.1.1 -r1.2
*** PGConnection.cs	12 Jul 2003 08:11:21 -0000	1.1.1.1
--- PGConnection.cs	12 Jul 2003 13:57:59 -0000	1.2
***************
*** 428,431 ****
--- 428,436 ----
  		public DataTable GetDbSchemaTable(PGDbSchemaType schema, object[] restrictions)
  		{
+ 			if (DataReader != null)
+ 			{
+ 				throw new InvalidOperationException("GetDbSchemaTable requires an open and available Connection. The connection's current state is Open, Fetching.");
+ 			}
+ 
  			IDbSchema dbSchema = PGDbSchemaFactory.GetSchema(schema);
  
***************
*** 447,450 ****
--- 452,460 ----
  		public void CreateDatabase(string database, string owner, string location, string template, string encoding)
  		{
+ 			if (DataReader != null)
+ 			{
+ 				throw new InvalidOperationException("CreateDatabase requires an open and available Connection. The connection's current state is Open, Fetching.");
+ 			}
+ 
  			if (database == null)
  			{