//
-// System.Data.Oracle.OracleCommandBuilder
+// System.Data.OracleClient.OracleCommandBuilder.cs
//
-// Author:
+// based on the SqlCommandBuilder in mcs/class/System.Data/System.Data.SqlClient
+//
+// Authors:
// Atsushi Enomoto <atsushi@ximian.com>
+// Tim Coleman (tim@timcoleman.com)
+// Daniel Morgan <danielmorgan@verizon.net>
+//
+// Copyright (C) Tim Coleman, 2002
+// Copyright (C) Daniel Morgan, 2005
+// Copyright (C) 2004 Novell, Inc (http://www.novell.com)
//
-// (C)2004 Novell Inc.
+// Permission is hereby granted, free of charge, to any person obtaining
+// a copy of this software and associated documentation files (the
+// "Software"), to deal in the Software without restriction, including
+// without limitation the rights to use, copy, modify, merge, publish,
+// distribute, sublicense, and/or sell copies of the Software, and to
+// permit persons to whom the Software is furnished to do so, subject to
+// the following conditions:
+//
+// The above copyright notice and this permission notice shall be
+// included in all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
+// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
+// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
+// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
//
+using System;
+using System.Collections;
using System.ComponentModel;
using System.Data;
using System.Data.Common;
+using System.Text;
-namespace System.Data.OracleClient
-{
+namespace System.Data.OracleClient {
+#if NET_2_0
+ public sealed class OracleCommandBuilder : DbCommandBuilder
+#else
public sealed class OracleCommandBuilder : Component
+#endif // NET_2_0
{
#region Fields
+ bool disposed = false;
+
+ DataTable dbSchemaTable;
OracleDataAdapter adapter;
string quotePrefix;
string quoteSuffix;
+ string[] columnNames;
+ string tableName;
+
+ OracleCommand deleteCommand;
+ OracleCommand insertCommand;
+ OracleCommand updateCommand;
+
+ // Used to construct WHERE clauses
+ static readonly string clause1 = "({0} IS NULL AND {1} IS NULL)";
+ static readonly string clause2 = "({0} = {1})";
#endregion // Fields
#region Constructors
-
- public OracleCommandBuilder ()
- {
+
+ public OracleCommandBuilder () {
+ dbSchemaTable = null;
adapter = null;
- quotePrefix = String.Empty;
quoteSuffix = String.Empty;
+ quotePrefix = String.Empty;
}
- public OracleCommandBuilder (OracleDataAdapter adapter)
- : this ()
- {
- this.adapter = adapter;
+ public OracleCommandBuilder (OracleDataAdapter adapter)
+ : this () {
+ DataAdapter = adapter;
}
#endregion // Constructors
#region Properties
+ [DataSysDescription ("The DataAdapter for which to automatically generate OracleCommands")]
[DefaultValue (null)]
- public OracleDataAdapter DataAdapter {
- get {
- return adapter;
- }
- set {
- adapter = value;
+ public new OracleDataAdapter DataAdapter {
+ get { return adapter; }
+ set {
+ if (adapter != null)
+ adapter.RowUpdating -= new OracleRowUpdatingEventHandler (RowUpdatingHandler);
+
+ adapter = value;
+
+ if (adapter != null)
+ adapter.RowUpdating += new OracleRowUpdatingEventHandler (RowUpdatingHandler);
}
}
- [BrowsableAttribute (false)]
- [DesignerSerializationVisibilityAttribute (DesignerSerializationVisibility.Hidden)]
- public string QuotePrefix {
- get {
- return quotePrefix;
+ private string QuotedTableName {
+ get { return GetQuotedString (tableName); }
+ }
+
+ [Browsable (false)]
+ [DataSysDescription ("The character used in a text command as the opening quote for quoting identifiers that contain special characters.")]
+ [DesignerSerializationVisibility (DesignerSerializationVisibility.Hidden)]
+ public
+#if NET_2_0
+ override
+#endif // NET_2_0
+ string QuotePrefix {
+ get { return quotePrefix; }
+ set {
+ if (dbSchemaTable != null)
+ throw new InvalidOperationException ("The QuotePrefix and QuoteSuffix properties cannot be changed once an Insert, Update, or Delete command has been generated.");
+ quotePrefix = value;
}
+ }
+
+ [Browsable (false)]
+ [DataSysDescription ("The character used in a text command as the closing quote for quoting identifiers that contain special characters.")]
+ [DesignerSerializationVisibility (DesignerSerializationVisibility.Hidden)]
+ public
+#if NET_2_0
+ override
+#endif // NET_2_0
+ string QuoteSuffix {
+ get { return quoteSuffix; }
set {
- quotePrefix = value;
+ if (dbSchemaTable != null)
+ throw new InvalidOperationException ("The QuotePrefix and QuoteSuffix properties cannot be changed once an Insert, Update, or Delete command has been generated.");
+ quoteSuffix = value;
}
}
- [BrowsableAttribute (false)]
- [DesignerSerializationVisibilityAttribute (DesignerSerializationVisibility.Hidden)]
- public string QuoteSuffix {
+ private OracleCommand SourceCommand {
get {
- return quoteSuffix;
- }
- set {
- quoteSuffix = value;
+ if (adapter != null)
+ return adapter.SelectCommand;
+ return null;
}
}
#region Methods
+ private void BuildCache (bool closeConnection)
+ {
+ OracleCommand sourceCommand = SourceCommand;
+ if (sourceCommand == null)
+ throw new InvalidOperationException ("The DataAdapter.SelectCommand property needs to be initialized.");
+ OracleConnection connection = sourceCommand.Connection;
+ if (connection == null)
+ throw new InvalidOperationException ("The DataAdapter.SelectCommand.Connection property needs to be initialized.");
+
+ if (dbSchemaTable == null) {
+ if (connection.State == ConnectionState.Open)
+ closeConnection = false;
+ else
+ connection.Open ();
+
+ OracleDataReader reader = sourceCommand.ExecuteReader (CommandBehavior.SchemaOnly | CommandBehavior.KeyInfo);
+ dbSchemaTable = reader.GetSchemaTable ();
+ reader.Close ();
+ if (closeConnection)
+ connection.Close ();
+ BuildInformation (dbSchemaTable);
+ }
+ }
+
+ private void BuildInformation (DataTable schemaTable)
+ {
+ tableName = String.Empty;
+ foreach (DataRow schemaRow in schemaTable.Rows) {
+ if (tableName == String.Empty)
+ tableName = schemaRow.IsNull ("BaseTableName") ? null : (string) schemaRow ["BaseTableName"];
+ else if (schemaRow.IsNull ("BaseTableName")) {
+ if (tableName != null)
+ throw new InvalidOperationException ("Dynamic SQL generation is not supported against multiple base tables.");
+ } else if (tableName != (string) schemaRow["BaseTableName"])
+ throw new InvalidOperationException ("Dynamic SQL generation is not supported against multiple base tables.");
+ }
+ dbSchemaTable = schemaTable;
+ }
+
+ private OracleCommand CreateDeleteCommand (DataRow row, DataTableMapping tableMapping)
+ {
+ // If no table was found, then we can't do an delete
+ if (QuotedTableName == String.Empty)
+ return null;
+
+
+ CreateNewCommand (ref deleteCommand);
+
+ string command = String.Format ("DELETE FROM {0} ", QuotedTableName);
+ StringBuilder whereClause = new StringBuilder ();
+ string dsColumnName = String.Empty;
+ bool keyFound = false;
+ int parmIndex = 1;
+
+ foreach (DataRow schemaRow in dbSchemaTable.Rows) {
+ if (!IncludedInWhereClause (schemaRow))
+ continue;
+
+ if (whereClause.Length > 0)
+ whereClause.Append (" AND ");
+
+ bool isKey = (bool) schemaRow ["IsKey"];
+ OracleParameter parameter = null;
+
+ if (!isKey) {
+ parameter = deleteCommand.Parameters.Add (CreateParameter (parmIndex++, schemaRow));
+ parameter.SourceVersion = DataRowVersion.Original;
+
+ dsColumnName = parameter.SourceColumn;
+ if (tableMapping != null
+ && tableMapping.ColumnMappings.Contains (parameter.SourceColumn))
+ dsColumnName = tableMapping.ColumnMappings [parameter.SourceColumn].DataSetColumn;
+
+ if (row != null)
+ parameter.Value = row [dsColumnName, DataRowVersion.Original];
+ whereClause.Append ("(");
+ whereClause.Append (String.Format (clause1, GetQuotedString (parameter.SourceColumn), ":" + parameter.ParameterName));
+ whereClause.Append (" OR ");
+ }
+ else
+ keyFound = true;
+
+ parameter = deleteCommand.Parameters.Add (CreateParameter (parmIndex++, schemaRow));
+ parameter.SourceVersion = DataRowVersion.Original;
+
+ dsColumnName = parameter.SourceColumn;
+ if (tableMapping != null
+ && tableMapping.ColumnMappings.Contains (parameter.SourceColumn))
+ dsColumnName = tableMapping.ColumnMappings [parameter.SourceColumn].DataSetColumn;
+
+ if (row != null)
+ parameter.Value = row [dsColumnName, DataRowVersion.Original];
+
+ whereClause.Append (String.Format (clause2, GetQuotedString (parameter.SourceColumn), ":" + parameter.ParameterName));
+
+ if (!isKey)
+ whereClause.Append (")");
+ }
+ if (!keyFound)
+ throw new InvalidOperationException ("Dynamic SQL generation for the DeleteCommand is not supported against a SelectCommand that does not return any key column information.");
+
+ // We're all done, so bring it on home
+ string sql = String.Format ("{0} WHERE ( {1} )", command, whereClause.ToString ());
+ deleteCommand.CommandText = sql;
+ return deleteCommand;
+ }
+
+ private OracleCommand CreateInsertCommand (DataRow row, DataTableMapping tableMapping)
+ {
+ if (QuotedTableName == String.Empty)
+ return null;
+
+ CreateNewCommand (ref insertCommand);
+
+ string command = String.Format ("INSERT INTO {0}", QuotedTableName);
+ string sql;
+ StringBuilder columns = new StringBuilder ();
+ StringBuilder values = new StringBuilder ();
+ string dsColumnName = String.Empty;
+
+ int parmIndex = 1;
+ foreach (DataRow schemaRow in dbSchemaTable.Rows) {
+ if (!IncludedInInsert (schemaRow))
+ continue;
+
+ if (parmIndex > 1) {
+ columns.Append (" , ");
+ values.Append (" , ");
+ }
+
+ OracleParameter parameter = insertCommand.Parameters.Add (CreateParameter (parmIndex++, schemaRow));
+ parameter.SourceVersion = DataRowVersion.Current;
+
+ dsColumnName = parameter.SourceColumn;
+ if (tableMapping != null
+ && tableMapping.ColumnMappings.Contains (parameter.SourceColumn))
+ dsColumnName = tableMapping.ColumnMappings [parameter.SourceColumn].DataSetColumn;
+
+ if (row != null)
+ parameter.Value = row [dsColumnName, DataRowVersion.Current];
+
+ columns.Append (GetQuotedString (parameter.SourceColumn));
+ values.Append (":" + parameter.ParameterName);
+ }
+
+ sql = String.Format ("{0}( {1} ) VALUES ( {2} )", command, columns.ToString (), values.ToString ());
+ insertCommand.CommandText = sql;
+ return insertCommand;
+ }
+
+ private void CreateNewCommand (ref OracleCommand command) {
+ OracleCommand sourceCommand = SourceCommand;
+ if (command == null) {
+ command = sourceCommand.Connection.CreateCommand ();
+ command.Transaction = sourceCommand.Transaction;
+ }
+ command.CommandType = CommandType.Text;
+ command.UpdatedRowSource = UpdateRowSource.None;
+ }
+
+ private OracleCommand CreateUpdateCommand (DataRow row, DataTableMapping tableMapping)
+ {
+ // If no table was found, then we can't do an update
+ if (QuotedTableName == String.Empty)
+ return null;
+
+ CreateNewCommand (ref updateCommand);
+
+ string command = String.Format ("UPDATE {0} SET ", QuotedTableName);
+ StringBuilder columns = new StringBuilder ();
+ StringBuilder whereClause = new StringBuilder ();
+ int parmIndex = 1;
+ string dsColumnName = String.Empty;
+ bool keyFound = false;
+
+ // First, create the X=Y list for UPDATE
+ foreach (DataRow schemaRow in dbSchemaTable.Rows) {
+ if (columns.Length > 0)
+ columns.Append (" , ");
+
+ OracleParameter parameter = updateCommand.Parameters.Add (CreateParameter (parmIndex++, schemaRow));
+ parameter.SourceVersion = DataRowVersion.Current;
+
+ dsColumnName = parameter.SourceColumn;
+ if (tableMapping != null
+ && tableMapping.ColumnMappings.Contains (parameter.SourceColumn))
+ dsColumnName = tableMapping.ColumnMappings [parameter.SourceColumn].DataSetColumn;
+
+ if (row != null)
+ parameter.Value = row [dsColumnName, DataRowVersion.Current];
+
+ columns.Append (String.Format ("{0} = {1}", GetQuotedString (parameter.SourceColumn), ":" + parameter.ParameterName));
+ }
+
+ // Now, create the WHERE clause. This may be optimizable, but it would be ugly to incorporate
+ // into the loop above. "Premature optimization is the root of all evil." -- Knuth
+ foreach (DataRow schemaRow in dbSchemaTable.Rows) {
+ if (!IncludedInWhereClause (schemaRow))
+ continue;
+
+ if (whereClause.Length > 0)
+ whereClause.Append (" AND ");
+
+ bool isKey = (bool) schemaRow ["IsKey"];
+ OracleParameter parameter = null;
+
+ if (!isKey) {
+ parameter = updateCommand.Parameters.Add (CreateParameter (parmIndex++, schemaRow));
+ parameter.SourceVersion = DataRowVersion.Original;
+
+ dsColumnName = parameter.SourceColumn;
+ if (tableMapping != null
+ && tableMapping.ColumnMappings.Contains (parameter.SourceColumn))
+ dsColumnName = tableMapping.ColumnMappings [parameter.SourceColumn].DataSetColumn;
+
+ if (row != null)
+ parameter.Value = row [dsColumnName, DataRowVersion.Original];
+
+ whereClause.Append ("(");
+ whereClause.Append (String.Format (clause1, GetQuotedString (parameter.SourceColumn), ":" + parameter.ParameterName));
+ whereClause.Append (" OR ");
+ }
+ else
+ keyFound = true;
+
+ parameter = updateCommand.Parameters.Add (CreateParameter (parmIndex++, schemaRow));
+ parameter.SourceVersion = DataRowVersion.Original;
+
+ dsColumnName = parameter.SourceColumn;
+ if (tableMapping != null
+ && tableMapping.ColumnMappings.Contains (parameter.SourceColumn))
+ dsColumnName = tableMapping.ColumnMappings [parameter.SourceColumn].DataSetColumn;
+
+ if (row != null)
+ parameter.Value = row [dsColumnName, DataRowVersion.Original];
+
+ whereClause.Append (String.Format (clause2, GetQuotedString (parameter.SourceColumn), ":" + parameter.ParameterName));
+
+ if (!isKey)
+ whereClause.Append (")");
+ }
+ if (!keyFound)
+ throw new InvalidOperationException ("Dynamic SQL generation for the UpdateCommand is not supported against a SelectCommand that does not return any key column information.");
+
+ // We're all done, so bring it on home
+ string sql = String.Format ("{0}{1} WHERE ( {2} )", command, columns.ToString (), whereClause.ToString ());
+ updateCommand.CommandText = sql;
+ return updateCommand;
+ }
+
+ private OracleParameter CreateParameter (int parmIndex, DataRow schemaRow)
+ {
+ string name = String.Format ("p{0}", parmIndex);
+
+ string sourceColumn = (string) schemaRow ["BaseColumnName"];
+ int providerType = (int) schemaRow ["ProviderType"];
+ OracleType providerDbType = (OracleType) providerType;
+ int size = (int) schemaRow ["ColumnSize"];
+
+ return new OracleParameter (name, providerDbType, size, sourceColumn);
+ }
+
public static void DeriveParameters (OracleCommand command)
{
- throw new NotImplementedException ();
+ command.DeriveParameters ();
}
- [MonoTODO]
protected override void Dispose (bool disposing)
{
- throw new NotImplementedException ();
+ if (!disposed) {
+ if (disposing) {
+ if (insertCommand != null)
+ insertCommand.Dispose ();
+ if (deleteCommand != null)
+ deleteCommand.Dispose ();
+ if (updateCommand != null)
+ updateCommand.Dispose ();
+ if (dbSchemaTable != null)
+ dbSchemaTable.Dispose ();
+ }
+ disposed = true;
+ }
+ }
+
+ public
+#if NET_2_0
+ new
+#endif // NET_2_0
+ OracleCommand GetDeleteCommand ()
+ {
+ BuildCache (true);
+ return CreateDeleteCommand (null, null);
}
- [MonoTODO]
- public OracleCommand GetDeleteCommand ()
+ public
+#if NET_2_0
+ new
+#endif // NET_2_0
+ OracleCommand GetInsertCommand ()
{
- throw new NotImplementedException ();
+ BuildCache (true);
+ return CreateInsertCommand (null, null);
}
- [MonoTODO]
- public OracleCommand GetInsertCommand ()
+ private string GetQuotedString (string value)
{
- throw new NotImplementedException ();
+ if (value == String.Empty || value == null)
+ return value;
+ if (quotePrefix == String.Empty && quoteSuffix == String.Empty)
+ return value;
+ return String.Format ("{0}{1}{2}", quotePrefix, value, quoteSuffix);
}
- [MonoTODO]
- public OracleCommand GetUpdateCommand ()
+ public
+#if NET_2_0
+ new
+#endif // NET_2_0
+ OracleCommand GetUpdateCommand ()
{
- throw new NotImplementedException ();
+ BuildCache (true);
+ return CreateUpdateCommand (null, null);
+ }
+
+ private bool IncludedInInsert (DataRow schemaRow)
+ {
+ // If the parameter has one of these properties, then we don't include it in the insert:
+ if (!schemaRow.IsNull ("IsExpression") && (bool) schemaRow ["IsExpression"])
+ return false;
+ return true;
+ }
+
+ private bool IncludedInUpdate (DataRow schemaRow) {
+ // If the parameter has one of these properties, then we don't include it in the insert:
+ // AutoIncrement, Hidden, RowVersion
+
+ return true;
+ }
+
+ private bool IncludedInWhereClause (DataRow schemaRow) {
+ if ((bool) schemaRow ["IsLong"])
+ return false;
+ return true;
}
- [MonoTODO]
- public void RefreshSchema ()
+ [MonoTODO ("Figure out what else needs to be cleaned up when we refresh.")]
+ public
+#if NET_2_0
+ override
+#endif // NET_2_0
+ void RefreshSchema ()
{
- throw new NotImplementedException ();
+ tableName = String.Empty;
+ dbSchemaTable = null;
}
+#if NET_2_0
+ [MonoTODO]
+ protected override void ApplyParameterInfo (IDbDataParameter dbParameter, DataRow row)
+ {
+ throw new NotImplementedException ();
+ }
+
+ [MonoTODO]
+ protected override string GetParameterName (int position)
+ {
+ throw new NotImplementedException ();
+ }
+
+
+ [MonoTODO]
+ protected override string GetParameterPlaceholder (int position)
+ {
+ throw new NotImplementedException ();
+ }
+
+ [MonoTODO]
+ protected override DbProviderFactory ProviderFactory
+ {
+ get {throw new NotImplementedException ();}
+ }
+#endif // NET_2_0
#endregion // Methods
+
+ #region Event Handlers
+
+ private void RowUpdatingHandler (object sender, OracleRowUpdatingEventArgs args)
+ {
+ if (args.Command != null)
+ return;
+ try {
+ switch (args.StatementType) {
+ case StatementType.Insert:
+ args.Command = GetInsertCommand ();
+ break;
+ case StatementType.Update:
+ args.Command = GetUpdateCommand ();
+ break;
+ case StatementType.Delete:
+ args.Command = GetDeleteCommand ();
+ break;
+ }
+ } catch (Exception e) {
+ args.Errors = e;
+ args.Status = UpdateStatus.ErrorsOccurred;
+ }
+ }
+
+#if NET_2_0
+ [MonoTODO]
+ protected override void SetRowUpdatingHandler (DbDataAdapter adapter)
+ {
+ throw new NotImplementedException ();
+ }
+#endif // NET_2_0
+
+ #endregion // Event Handlers
}
}
+
projects / mono.git / blobdiff