[pgsqlclient-checkins] SF.net SVN: pgsqlclient: [148] trunk/PostgreSqlClient/source/PostgreSql/Data/PostgreSqlClient/PgCommandBuilder.cs

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

Revision: 148
Author:   carlosga_fb
Date:     2006-05-19 02:22:07 -0700 (Fri, 19 May 2006)
ViewCVS:  http://svn.sourceforge.net/pgsqlclient/?rev=148&view=rev

Log Message:
-----------


Modified Paths:
--------------
    trunk/PostgreSqlClient/source/PostgreSql/Data/PostgreSqlClient/PgCommandBuilder.cs
Modified: trunk/PostgreSqlClient/source/PostgreSql/Data/PostgreSqlClient/PgCommandBuilder.cs
===================================================================
--- trunk/PostgreSqlClient/source/PostgreSql/Data/PostgreSqlClient/PgCommandBuilder.cs	2006-05-19 08:36:12 UTC (rev 147)
+++ trunk/PostgreSqlClient/source/PostgreSql/Data/PostgreSqlClient/PgCommandBuilder.cs	2006-05-19 09:22:07 UTC (rev 148)
@@ -18,6 +18,7 @@
 using System;
 using System.Data;
 using System.Data.Common;
+using System.Globalization;
 using System.Text;
 using System.ComponentModel;
 
@@ -32,6 +33,92 @@
         /// <include file='Doc/en_EN/FbCommandBuilder.xml' path='doc/class[@name="FbCommandBuilder"]/method[@name="DeriveParameters(PgCommand)"]/*'/>
         public static void DeriveParameters(PgCommand command)
         {
+            if (command.CommandType != CommandType.StoredProcedure)
+            {
+                throw new InvalidOperationException("The command text is not a valid stored procedure name.");
+            }
+
+            string originalSpName   = command.CommandText.Trim();
+            string schemaName       = "";
+            string spName           = "";
+            string quotePrefix      = "\"";
+            string quoteSuffix      = "\"";
+
+            if (originalSpName.Contains("."))
+            {
+                string[] parts = originalSpName.Split(new char[] { '.' }, StringSplitOptions.RemoveEmptyEntries);
+
+                if (parts.Length > 2)
+                {
+                    throw new InvalidOperationException("The command stored procedure name is not valid.");
+                }
+
+                schemaName  = parts[0];
+                spName      = parts[1];
+            }
+            else
+            {
+                spName = originalSpName;
+            }
+
+            if (schemaName.StartsWith(quotePrefix) && schemaName.EndsWith(quoteSuffix))
+            {
+                schemaName = schemaName.Substring(1, spName.Length - 2);
+            }
+            else
+            {
+                schemaName = schemaName.ToUpper(CultureInfo.CurrentUICulture);
+            }
+
+            if (spName.StartsWith(quotePrefix) && spName.EndsWith(quoteSuffix))
+            {
+                spName = spName.Substring(1, spName.Length - 2);
+            }
+            else
+            {
+                spName = spName.ToUpper(CultureInfo.CurrentUICulture);
+            }
+
+            string paramsText = String.Empty;
+
+            command.Parameters.Clear();
+
+            DataView dataTypes = command.Connection.GetSchema("DataTypes").DefaultView;
+
+            DataTable spSchema = command.Connection.GetSchema(
+                "FunctionParameters", new string[] { null, schemaName, spName });
+
+            int count = 1;
+            foreach (DataRow row in spSchema.Rows)
+            {
+                dataTypes.RowFilter = String.Format(
+                    CultureInfo.CurrentUICulture,
+                    "TypeName = '{0}'",
+                    row["PARAMETER_DATA_TYPE"]);
+
+                PgParameter parameter = command.Parameters.Add(
+                    "@" + row["PARAMETER_NAME"].ToString().Trim(),
+                    PgDbType.VarChar);
+
+                parameter.PgDbType  = (PgDbType)dataTypes[0]["ProviderDbType"];
+                parameter.Direction = (ParameterDirection)row["PARAMETER_DIRECTION"];
+                parameter.Size      = Convert.ToInt32(row["PARAMETER_SIZE"], CultureInfo.InvariantCulture);
+
+                if (parameter.PgDbType == PgDbType.Decimal ||
+                    parameter.PgDbType == PgDbType.Numeric)
+                {
+                    if (row["NUMERIC_PRECISION"] != DBNull.Value)
+                    {
+                        parameter.Precision = Convert.ToByte(row["NUMERIC_PRECISION"], CultureInfo.InvariantCulture);
+                    }
+                    if (row["NUMERIC_SCALE"] != DBNull.Value)
+                    {
+                        parameter.Scale = Convert.ToByte(row["NUMERIC_SCALE"], CultureInfo.InvariantCulture);
+                    }
+                }
+
+                count++;
+            }
         }
 
         #endregion


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.