1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
//
// System.Data.SqlClient.SqlDataAdapter.cs
//
// Author:
// Rodrigo Moya (rodrigo@ximian.com)
// Daniel Morgan (danmorg@sc.rr.com)
// Tim Coleman (tim@timcoleman.com)
//
// (C) Ximian, Inc 2002
// Copyright (C) 2002 Tim Coleman
//
using System;
using System.ComponentModel;
using System.Data;
using System.Data.Common;
namespace System.Data.SqlClient
{
/// <summary>
/// Represents a set of command-related properties that are used
/// to fill the DataSet and update a data source, all this
/// from a SQL database.
/// </summary>
public sealed class SqlDataAdapter : DbDataAdapter, IDbDataAdapter
{
#region Fields
SqlCommand deleteCommand;
SqlCommand insertCommand;
SqlCommand selectCommand;
SqlCommand updateCommand;
static readonly object EventRowUpdated = new object();
static readonly object EventRowUpdating = new object();
#endregion
#region Constructors
public SqlDataAdapter ()
: this (new SqlCommand ())
{
}
public SqlDataAdapter (SqlCommand selectCommand)
{
DeleteCommand = new SqlCommand ();
InsertCommand = new SqlCommand ();
SelectCommand = selectCommand;
UpdateCommand = new SqlCommand ();
}
public SqlDataAdapter (string selectCommandText, SqlConnection selectConnection)
: this (new SqlCommand (selectCommandText, selectConnection))
{
}
public SqlDataAdapter (string selectCommandText, string selectConnectionString)
: this (selectCommandText, new SqlConnection (selectConnectionString))
{
}
#endregion
#region Properties
public new SqlCommand DeleteCommand {
get { return deleteCommand; }
set { deleteCommand = value; }
}
public new SqlCommand InsertCommand {
get { return insertCommand; }
set { insertCommand = value; }
}
public new SqlCommand SelectCommand {
get { return selectCommand; }
set { selectCommand = value; }
}
public new SqlCommand UpdateCommand {
get { return updateCommand; }
set { updateCommand = value; }
}
IDbCommand IDbDataAdapter.DeleteCommand {
get { return DeleteCommand; }
set {
if (!(value is SqlCommand))
throw new ArgumentException ();
DeleteCommand = (SqlCommand)value;
}
}
IDbCommand IDbDataAdapter.InsertCommand {
get { return InsertCommand; }
set {
if (!(value is SqlCommand))
throw new ArgumentException ();
InsertCommand = (SqlCommand)value;
}
}
IDbCommand IDbDataAdapter.SelectCommand {
get { return SelectCommand; }
set {
if (!(value is SqlCommand))
throw new ArgumentException ();
SelectCommand = (SqlCommand)value;
}
}
IDbCommand IDbDataAdapter.UpdateCommand {
get { return UpdateCommand; }
set {
if (!(value is SqlCommand))
throw new ArgumentException ();
UpdateCommand = (SqlCommand)value;
}
}
ITableMappingCollection IDataAdapter.TableMappings {
get { return TableMappings; }
}
#endregion // Properties
#region Methods
protected override RowUpdatedEventArgs CreateRowUpdatedEvent (DataRow dataRow, IDbCommand command, StatementType statementType, DataTableMapping tableMapping)
{
return new SqlRowUpdatedEventArgs (dataRow, command, statementType, tableMapping);
}
protected override RowUpdatingEventArgs CreateRowUpdatingEvent (DataRow dataRow, IDbCommand command, StatementType statementType, DataTableMapping tableMapping)
{
return new SqlRowUpdatingEventArgs (dataRow, command, statementType, tableMapping);
}
protected override void OnRowUpdated (RowUpdatedEventArgs value)
{
SqlRowUpdatedEventHandler handler = (SqlRowUpdatedEventHandler) Events[EventRowUpdated];
if ((handler != null) && (value is SqlRowUpdatedEventArgs))
handler(this, (SqlRowUpdatedEventArgs) value);
}
protected override void OnRowUpdating (RowUpdatingEventArgs value)
{
SqlRowUpdatingEventHandler handler = (SqlRowUpdatingEventHandler) Events[EventRowUpdating];
if ((handler != null) && (value is SqlRowUpdatingEventArgs))
handler(this, (SqlRowUpdatingEventArgs) value);
}
#endregion // Methods
#region Events and Delegates
public event SqlRowUpdatedEventHandler RowUpdated {
add { Events.AddHandler (EventRowUpdated, value); }
remove { Events.RemoveHandler (EventRowUpdated, value); }
}
public event SqlRowUpdatingEventHandler RowUpdating {
add { Events.AddHandler (EventRowUpdating, value); }
remove { Events.RemoveHandler (EventRowUpdating, value); }
}
#endregion // Events and Delegates
}
}
|
