1 ODP_Inserter2 {3 ///

4 ///数据库连接串5 ///

6 private string strWMSConn = string.Empty;7

8 public stringStrWMSConn9 {10 get

11 {12 if (strWMSConn == string.Empty)13 {14 returnGetConnectionString();15 }16 else

17 {18 returnstrWMSConn;19 }20 }21 }22

23 ///

24 ///构造函数25 ///

26 publicOracleAccessBatcher()27 {28 //加载数据库连接串

29 if (strWMSConn == string.Empty)30 {31 GetConnectionString();32 }33 }34

35 ///

36 ///加载数据库连接串37 ///

38 private stringGetConnectionString()39 {40 System.Configuration.AppSettingsReader reader = newSystem.Configuration.AppSettingsReader();41 strWMSConn = reader.GetValue("B2BDataBase", typeof(string)).ToString();42 returnstrWMSConn;43 }44

45 ///

46 ///批量插入数据47 ///

48 /// 目的表名称

49 /// 数据源(列名与目的表一致)

50 ///

51 public void BatchInsert(stringtableName, DataTable dataTable)52 {53 if (string.IsNullOrEmpty(tableName))54 {55 throw new ArgumentNullException("tableName", "必须指定批量插入的表名称");56 }57

58 if (dataTable == null || dataTable.Rows.Count < 1)59 {60 throw new ArgumentException("必须指定批量插入的数据源", "dataTable");61 }62

63 using (OracleConnection conn = newOracleConnection(strWMSConn))64 {65 try

66 {67 conn.Open();68

69 using (OracleCommand cmd =conn.CreateCommand())70 {71 //绑定批处理的行数

72 cmd.ArrayBindCount =dataTable.Rows.Count;73 cmd.BindByName = true;74 cmd.CommandType =CommandType.Text;75 cmd.CommandText =GenerateInsertSql(cmd, tableName, dataTable);76 cmd.CommandTimeout = 600; //10分钟

77

78 cmd.ExecuteNonQuery();79 }80 }81 catch(Exception exp)82 {83 throwexp;84 }85 finally

86 {87 conn.Close();88 }89 }90

91 }92

93 ///

94 ///批量更新数据95 ///

96 /// 目的表名

97 /// 条件列名数组(值与目的表列名一致)

98 /// 数据源(列名与目的表一致)

99 ///

100 public int BatchUpdate(string tableName, string[] keyColumns, DataTable dataTable)101 {102 //检查输入

103 if (string.IsNullOrEmpty(tableName))104 {105 throw new ArgumentNullException("tableName", "必须指定批量更新的表名称");106 }107

108 if (keyColumns == null || keyColumns.Length == 0)109 {110 throw new ArgumentException("必须指定批量更新表的条件列数组", "keyColumns");111 }112

113 if (dataTable == null || dataTable.Rows.Count < 1)114 {115 throw new ArgumentException("必须指定批量更新的数据源", "dataTable");116 }117

118 //无需更新

119 if (keyColumns.Length >=dataTable.Columns.Count)120 {121 throw new ArgumentException("目的表不存在需要更新的列名", "keyColumns&dataTable");122 }123

124 //条件列是否在表列名中

125 foreach (string colName inkeyColumns)126 {127 if (!dataTable.Columns.Contains(colName))128 {129 throw new ArgumentException("用于更新条件的列名不在目的表中", "dataTable");130 }131 }132

133 int iResult = 0;134 using (OracleConnection conn = newOracleConnection(strWMSConn))135 {136 try

137 {138 conn.Open();139

140 using (OracleCommand cmd =conn.CreateCommand())141 {142 //绑定批处理的行数

143 cmd.ArrayBindCount =dataTable.Rows.Count;144 cmd.BindByName = true;145 cmd.CommandType =CommandType.Text;146 cmd.CommandText =GenerateUpdateSql(cmd, tableName, keyColumns, dataTable);147 cmd.CommandTimeout = 600; //10分钟

148

149 iResult =cmd.ExecuteNonQuery();150 }151 }152 catch(Exception exp)153 {154 throwexp;155 }156 finally

157 {158 conn.Close();159 }160 }161

162 returniResult;163 }164

165 ///

166 ///批量删除167 ///

168 /// 目标表

169 /// 列名(与目的表列名一致)

170 /// 列值

171 public void BatchDelete(string tableName, string columnName, stringcolumnValue)172 {173 //检查输入

174 if (string.IsNullOrEmpty(tableName))175 {176 throw new ArgumentNullException("tableName", "必须指定批量更新的表名称");177 }178

179 if (string.IsNullOrEmpty(columnName))180 {181 throw new ArgumentNullException("columnValue", "必须指定删除条件的列名");182 }183

184 string strCmdText = string.Format("delete from {0} where {1} = '{2}'", tableName, columnName, columnValue);185

186 using (OracleConnection conn = newOracleConnection(strWMSConn))187 {188 try

189 {190 conn.Open();191

192 using (OracleCommand cmd =conn.CreateCommand())193 {194 //绑定批处理的行数195 //cmd.ArrayBindCount = dataTable.Rows.Count;

196 cmd.BindByName = true;197 cmd.CommandType =CommandType.Text;198 cmd.CommandText =strCmdText;199 cmd.CommandTimeout = 600; //10分钟

200

201 cmd.ExecuteNonQuery();202 }203 }204 catch(Exception exp)205 {206 throwexp;207 }208 finally

209 {210 conn.Close();211 }212 }213 }214

215 ///

216 ///生成插入数据的sql语句217 ///

218 /// SQL命令

219 /// 目的表名称

220 /// 目的表数据

221 ///

222 private string GenerateInsertSql(OracleCommand command, stringtableName, DataTable table)223 {224 int cols =table.Columns.Count;225 int rows =table.Rows.Count;226

227 StringBuilder names = newStringBuilder();228 StringBuilder values = newStringBuilder();229

230 for (int i = 0; i < cols; i++)231 {232 DataColumn column =table.Columns[i];233 OracleParameter param = new OracleParameter(column.ColumnName, this.GetOracleDbType(column.DataType));234 //OracleParameter param = new OracleParameter(column.ColumnName, OracleDbType.Varchar2);

235

236 string[] data = new string[rows];237 for (int j = 0; j < rows; j++)238 {239 data[j] =table.Rows[j][column.ColumnName].ToString().TrimEnd();240 }241

242 param.Direction =ParameterDirection.Input;243 param.Value =data;244 command.Parameters.Add(param);245

246 if (names.Length > 0)247 {248 names.Append(",");249 values.Append(",");250 }251 names.AppendFormat("{0}", column.ColumnName);252 values.AppendFormat("{0}{1}", ":", column.ColumnName);253 }254 return string.Format("INSERT INTO {0}({1}) VALUES ({2})", tableName, names, values);255 }256

257 ///

258 ///生成更新数据的sql语句259 ///

260 ///

261 ///

262 ///

263 ///

264 ///

265 private string GenerateUpdateSql(OracleCommand command, string tableName, string[] keyColumns, DataTable table)266 {267 int cols =table.Columns.Count;268 int rows =table.Rows.Count;269

270 StringBuilder sets = newStringBuilder();271 StringBuilder wheres = newStringBuilder();272

273 for (int i = 0; i < cols; i++)274 {275 DataColumn column =table.Columns[i];276

277 //是否为条件列

278 bool isCond = false;279 foreach (string cod inkeyColumns)280 {281 isCond =cod.Equals(column.ColumnName);282 if(isCond)283 {284 break;285 }286 }287

288

289 string[] data = new string[rows];290 for (int j = 0; j < rows; j++)291 {292 data[j] =table.Rows[j][column.ColumnName].ToString().TrimEnd();293 }294

295 //设定参数

296 OracleParameter param;297 OracleDbType dbType =OracleDbType.Varchar2;298

299 dbType = this.GetOracleDbType(column.DataType);300 param = newOracleParameter(column.ColumnName, dbType);301 param.Direction =ParameterDirection.Input;302 param.Value =data;303 command.Parameters.Add(param);304

305 //条件列

306 if(isCond)307 {308 if (wheres.Length > 0)309 {310 wheres.Append("and");311 }312

313 wheres.AppendFormat("{0} = :{0}", column.ColumnName);314 }315 else

316 {317 if (sets.Length > 0)318 {319 sets.Append(",");320 }321 sets.AppendFormat("{0} = :{0}", column.ColumnName);322 }323 }324 return string.Format("update {0} set {1} where {2}", tableName, sets, wheres);325 }326

327 ///

328 ///根据数据类型获取OracleDbType329 ///

330 ///

331 ///

332 private OracleDbType GetOracleDbType(objectvalue)333 {334 //OracleDbType dataType = OracleDbType.Object;

335 OracleDbType dataType =OracleDbType.Varchar2;336

337 if (value is string)338 {339 dataType =OracleDbType.Varchar2;340 }341 else if (value isDateTime)342 {343 dataType =OracleDbType.TimeStamp;344 }345 else if (value is int || value is short)346 {347 dataType =OracleDbType.Int32;348 }349 else if (value is long)350 {351 dataType =OracleDbType.Int64;352 }353 else if (value is decimal || value is double)354 {355 dataType =OracleDbType.Decimal;356 }357 else if (value isGuid)358 {359 dataType =OracleDbType.Varchar2;360 }361 else if (value is bool || value isBoolean)362 {363 dataType =OracleDbType.Byte;364 }365 else if (value is byte[])366 {367 dataType =OracleDbType.Blob;368 }369 else if (value is char)370 {371 dataType =OracleDbType.Char;372 }373

374 returndataType;375 }376

377 ///

378 ///执行SQL379 ///

380 ///

381 public void ExecuteSql(stringstrSql)382 {383 using (OracleConnection conn = newOracleConnection(strWMSConn))384 {385 try

386 {387 conn.Open();388

389 using (OracleCommand cmd =conn.CreateCommand())390 {391 cmd.BindByName = true;392 cmd.CommandType =CommandType.Text;393 cmd.CommandText =strSql;394 cmd.CommandTimeout = 600;395

396 cmd.ExecuteNonQuery();397 }398 }399 catch(Exception exp)400 {401 throwexp;402 }403 finally

404 {405 conn.Close();406 }407 }408 }409 }