Oracal.cs 35 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data;
  4. using System.Data.OleDb;
  5. using System.Linq;
  6. namespace BaseLibDataProcess
  7. {
  8. public class OraDBBase
  9. {
  10. public OleDbConnection oledbConn = null;
  11. /// <summary>
  12. /// 服务名
  13. /// </summary>
  14. public string strServerName { get; set; }
  15. /// <summary>
  16. /// 用户名
  17. /// </summary>
  18. public string strID { get; set; }
  19. /// <summary>
  20. /// 密码
  21. /// </summary>
  22. public string strPWD { get; set; }
  23. /// <summary>
  24. /// 连接字符串
  25. /// </summary>
  26. public string strConnectString { get; set; }
  27. /// <summary>
  28. /// 连接状态
  29. /// </summary>
  30. public bool bConnectState { get; set; }
  31. /// <summary>
  32. /// oracle数据库构造函数
  33. /// </summary>
  34. public OraDBBase()
  35. {
  36. }
  37. /// <summary>
  38. /// oracle数据库构造函数
  39. /// </summary>
  40. /// <param name="ServerName">服务名</param>
  41. /// <param name="ID">用户名</param>
  42. /// <param name="PWD">密码</param>
  43. public OraDBBase(string ServerName, string ID, string PWD)
  44. {
  45. strServerName = ServerName;
  46. strID = ID;
  47. strPWD = PWD;
  48. }
  49. /// <summary>
  50. /// 获得连接字符串
  51. /// </summary>
  52. /// <returns>连接字符串</returns>
  53. public string getConnectString()
  54. {
  55. if (string.IsNullOrEmpty(strServerName))
  56. {
  57. throw new OraDBBaseException("请设置服务名");
  58. }
  59. if (string.IsNullOrEmpty(strID))
  60. {
  61. throw new OraDBBaseException("请设置ID");
  62. }
  63. if (string.IsNullOrEmpty(strPWD))
  64. {
  65. throw new OraDBBaseException("请设置PWD");
  66. }
  67. strConnectString = "Provider=MSDAORA.1" +
  68. ";Data Source=" + strServerName +
  69. ";User Id=" + strID +
  70. ";Password=" + strPWD +
  71. ";Persist Security Info=False";
  72. return strConnectString;
  73. }
  74. /// <summary>
  75. /// 获取连接状态
  76. /// </summary>
  77. /// <returns>布尔值</returns>
  78. public bool getConnectState()
  79. {
  80. return bConnectState;
  81. }
  82. /// <summary>
  83. /// 获取指定字段的指定值的插入语句
  84. /// </summary>
  85. /// <param name="Table">表</param>
  86. /// <param name="FieldAndValue">字段和值</param>
  87. /// <returns>字符串值</returns>
  88. public static string getInsertString(string Table, string[,] arrFieldAndValue)
  89. {
  90. string strSQL = string.Empty;
  91. string str1 = "", str2 = "";
  92. strSQL = "insert into " + Table + "(";
  93. for (int i = 0; i < arrFieldAndValue.GetLength(0); i++)
  94. {
  95. str1 += string.Format("{0},", arrFieldAndValue[i, 0]);
  96. str2 += string.Format("'{0}',", arrFieldAndValue[i, 1]);
  97. }
  98. strSQL += str1.Substring(0, str1.Length - 1) + ") values (";
  99. strSQL += str2.Substring(0, str2.Length - 1) + ")";
  100. return strSQL;
  101. }
  102. /// <summary>
  103. /// 获取指定表的指定字段的指定值的插入语句
  104. /// </summary>
  105. /// <param name="Table">表</param>
  106. /// <param name="arrField">字段</param>
  107. /// <param name="arrValue">值</param>
  108. /// <returns>字符串值</returns>
  109. public static string getInsertString(string Table, string[] arrField, string[] arrValue)
  110. {
  111. if (arrField.Length != arrValue.Length)
  112. {
  113. throw new OraDBBaseException("字段的个数和值的个数不一致");
  114. }
  115. string str1 = "", str2 = "";
  116. string strSQL = "insert into " + Table + "(";
  117. for (int i = 0; i < arrField.Length; i++)
  118. {
  119. str1 += string.Format("{0},", arrField[i]);
  120. str2 += string.Format("'{0}',", arrValue[i]);
  121. }
  122. strSQL += str1.Substring(0, str1.Length - 1) + ") values (";
  123. strSQL += str2.Substring(0, str2.Length - 1) + ")";
  124. return strSQL;
  125. }
  126. /// <summary>
  127. /// 获取所有字段的所有值的插入语句
  128. /// </summary>
  129. /// <param name="Table">表</param>
  130. /// <param name="arrValue">值</param>
  131. /// <returns>字符串值</returns>
  132. public string getInsertString(string Table, string[] arrValue)
  133. {
  134. string strSQL = string.Empty;
  135. string[] arrField = getTableColumns(Table).ToArray();
  136. if (arrField.Length != arrValue.Length)
  137. {
  138. throw new OraDBBaseException("字段的个数和值的个数不一致");
  139. }
  140. string str1 = "", str2 = "";
  141. strSQL = "insert into " + Table + "(";
  142. for (int i = 0; i < arrField.Length; i++)
  143. {
  144. str1 += string.Format("{0},", arrField[i]);
  145. str2 += string.Format("'{0}',", arrValue[i]);
  146. }
  147. strSQL += str1.Substring(0, str1.Length - 1) + ") values (";
  148. strSQL += str2.Substring(0, str2.Length - 1) + ")";
  149. return strSQL;
  150. }
  151. /// <summary>
  152. /// 获取所有字段的所有值的插入语句
  153. /// </summary>
  154. /// <param name="Table">表</param>
  155. /// <param name="arrValue">值</param>
  156. /// <returns>字符串值</returns>
  157. public static string getInsertString2(string Table, string[] arrValue)
  158. {
  159. string str2 = "";
  160. string strSQL = "insert into " + Table + " values (";
  161. for (int i = 0; i < arrValue.Length; i++)
  162. {
  163. str2 += string.Format("'{0}',", arrValue[i]);
  164. }
  165. strSQL += str2.Substring(0, str2.Length - 1) + ")";
  166. return strSQL;
  167. }
  168. /// <summary>
  169. /// 获取有条件的指定字段的查询语句
  170. /// </summary>
  171. /// <param name="Table">表</param>
  172. /// <param name="arrFieldAndValue">字段和值</param>
  173. /// <returns>字符串值</returns>
  174. public static string getSelectString(string Table, string[,] arrFieldAndValue)
  175. {
  176. string strSQL = string.Empty;
  177. strSQL = string.Format("select * from {0} where ", Table);
  178. string str1 = "";
  179. for (int i = 0; i < arrFieldAndValue.GetLength(0); i++)
  180. {
  181. str1 += string.Format("{0}='{1}' and ", arrFieldAndValue[i, 0], arrFieldAndValue[i, 1]);
  182. }
  183. strSQL += str1.Substring(0, str1.Length - 5);
  184. return strSQL;
  185. }
  186. /// <summary>
  187. /// 获取有条件的指定字段的查询语句
  188. /// </summary>
  189. /// <param name="Table">表</param>
  190. /// <param name="arrField">字段</param>
  191. /// <param name="arrValue">值</param>
  192. /// <returns>字符串值</returns>
  193. public static string getSelectString(string Table, string[] arrField, string[] arrValue)
  194. {
  195. if (arrField.Length != arrValue.Length)
  196. {
  197. throw new OraDBBaseException("字段的个数和值的个数不一致");
  198. }
  199. string strSQL = string.Format("select * from {0} where ", Table);
  200. string str1 = "";
  201. for (int i = 0; i < arrField.Length; i++)
  202. {
  203. str1 += string.Format("{0}='{1}' and ", arrField[i], arrValue[i]);
  204. }
  205. strSQL += str1.Substring(0, str1.Length - 5);
  206. return strSQL;
  207. }
  208. /// <summary>
  209. /// 获取无条件的指定字段的查询语句
  210. /// </summary>
  211. /// <param name="Table">表</param>
  212. /// <param name="arrField">字段</param>
  213. /// <returns>字符串值</returns>
  214. public static string getSelectString(string Table, string[] arrField)
  215. {
  216. string str1 = "";
  217. string strSQL = "select ";
  218. for (int i = 0; i < arrField.Length; i++)
  219. {
  220. str1 += string.Format("{0},", arrField[i]);
  221. }
  222. strSQL += str1.Substring(0, str1.Length - 1) + " from " + Table;
  223. return strSQL;
  224. }
  225. /// <summary>
  226. /// 获取所有字段的查询语句
  227. /// </summary>
  228. /// <param name="Table">表</param>
  229. /// <returns>字符串值</returns>
  230. public string getSelectString2(string Table)
  231. {
  232. return string.Format("select * from {0}", Table);
  233. }
  234. /// <summary>
  235. /// 获取所有字段的查询语句
  236. /// </summary>
  237. /// <param name="Table">表</param>
  238. /// <returns>字符串值</returns>
  239. public string getSelectString(string Table)
  240. {
  241. string[] arrField = getTableColumns(Table).ToArray();
  242. string str1 = "";
  243. string strSQL = "select ";
  244. for (int i = 0; i < arrField.Length; i++)
  245. {
  246. str1 += string.Format("{0},", arrField[i]);
  247. }
  248. strSQL += str1.Substring(0, str1.Length - 1) + " from " + Table;
  249. return strSQL;
  250. }
  251. /// <summary>
  252. /// 获取创建表语句
  253. /// </summary>
  254. /// <param name="Table">表</param>
  255. /// <param name="FieldAndType">字段和类型</param>
  256. /// <returns>字符串值</returns>
  257. public static string getCreateString(string Table, string[,] FieldAndType)
  258. {
  259. string str1 = "";
  260. string strSQL = "create table " + Table + "(";
  261. for (int i = 0; i < FieldAndType.GetLength(0); i++)
  262. {
  263. str1 += string.Format("{0} {1},", FieldAndType[i, 0], FieldAndType[i, 1]);
  264. }
  265. strSQL += str1.Substring(0, str1.Length - 1) + ")";
  266. return strSQL;
  267. }
  268. /// <summary>
  269. /// 获取更新语句
  270. /// </summary>
  271. /// <param name="Table">表</param>
  272. /// <param name="FieldAndNewValue">新的字段和值</param>
  273. /// <param name="FieldAndOldValue">旧的字段和值</param>
  274. /// <returns>字符串值</returns>
  275. public static string getUpdateString(string Table, string[,] arrFieldAndNewValue, string[,] arrFieldAndOldValue)
  276. {
  277. string strSQL = string.Empty;
  278. string str1 = "update " + Table + " set ";
  279. for (int i = 0; i < arrFieldAndNewValue.GetLength(0); i++)
  280. {
  281. str1 += string.Format("{0}= '{1}',", arrFieldAndNewValue[i, 0], arrFieldAndNewValue[i, 1]);
  282. }
  283. string str2 = " where ";
  284. for (int i = 0; i < arrFieldAndOldValue.GetLength(0); i++)
  285. {
  286. str2 += string.Format("{0}= '{1}' and ", arrFieldAndOldValue[i, 0], arrFieldAndOldValue[i, 1]);
  287. }
  288. strSQL += str1.Substring(0, str1.Length - 1);
  289. strSQL += str2.Substring(0, str2.Length - 5);
  290. return strSQL;
  291. }
  292. /// <summary>
  293. /// 获取删除语句
  294. /// </summary>
  295. /// <param name="Table">表</param>
  296. /// <param name="Field">条件字段</param>
  297. /// <param name="Value">条件值</param>
  298. /// <returns>字符串值</returns>
  299. public static string getDeleteString(string Table, string Field, string Value)
  300. {
  301. return string.Format("delete from {0} where {1}='{2}'", Table, Field, Value);
  302. }
  303. /// <summary>
  304. /// 获取指定表的指定字段和值的删除语句
  305. /// </summary>
  306. /// <param name="Table">表名</param>
  307. /// <param name="arrField">条件字段</param>
  308. /// <param name="arrValue">条件值</param>
  309. /// <returns></returns>
  310. public static string getDeleteString(string Table, string[] arrField, string[] arrValue)
  311. {
  312. if (arrField.Length != arrValue.Length)
  313. {
  314. throw new OraDBBaseException("字段的个数和值的个数不一致");
  315. }
  316. string strSQL = string.Empty;
  317. string str1 = "";
  318. str1 = "delete from " + Table + " where ";
  319. for (int i = 0; i < arrField.Length; i++)
  320. {
  321. str1 += string.Format("{0}= '{1}' and ", arrField[i], arrValue[i]);
  322. }
  323. strSQL += str1.Substring(0, str1.Length - 5);
  324. return strSQL;
  325. }
  326. /// <summary>
  327. /// 获取指定表的指定字段和值的删除语句
  328. /// </summary>
  329. /// <param name="Table">表名</param>
  330. /// <param name="arrFieldAndValue">条件字段和值</param>
  331. /// <returns></returns>
  332. public static string getDeleteString(string Table, string[,] arrFieldAndValue)
  333. {
  334. string strSQL = string.Empty;
  335. string str1 = "delete from " + Table + " where ";
  336. for (int i = 0; i < arrFieldAndValue.GetLength(0); i++)
  337. {
  338. str1 += string.Format("{0}= '{1}' and ", arrFieldAndValue[i, 0], arrFieldAndValue[i, 1]);
  339. }
  340. strSQL += str1.Substring(0, str1.Length - 5);
  341. return strSQL;
  342. }
  343. /// <summary>
  344. /// 获取删除语句
  345. /// </summary>
  346. /// <param name="Table">表</param>
  347. /// <returns>字符串值</returns>
  348. public string getDeleteString(string Table)
  349. {
  350. return string.Format("delete from {0}", Table);
  351. }
  352. /// <summary>
  353. /// 获取删除表语句
  354. /// </summary>
  355. /// <param name="Table"></param>
  356. /// <returns>字符串值</returns>
  357. public string getDropString(string Table)
  358. {
  359. return string.Format("drop table {0}", Table);
  360. }
  361. public string[] List2Arr(List<string> list)
  362. {
  363. return list.ToArray();
  364. }
  365. public List<string> List2Arr(string[] arr)
  366. {
  367. return arr.ToList<string>();
  368. }
  369. public static string[,] List2Arr(List<string[]> list)
  370. {
  371. if (list.Count > 0)
  372. {
  373. string[,] arr = new string[list.Count, list[0].Length];
  374. for (int i = 0; i < list.Count; i++)
  375. {
  376. for (int j = 0; j < list[0].Length; j++)
  377. {
  378. arr[i, j] = list[i][j];
  379. }
  380. }
  381. return arr;
  382. }
  383. return null;
  384. }
  385. public static List<string[]> List2Arr(string[,] arr)
  386. {
  387. List<string[]> v = new List<string[]>();
  388. for (int i = 0; i < arr.GetLength(0); i++)
  389. {
  390. string[] arr1 = new string[arr.GetLength(1)];
  391. for (int j = 0; j < arr.GetLength(1); j++)
  392. {
  393. arr1[j] = arr[i, j];
  394. }
  395. v.Add(arr1);
  396. }
  397. return v;
  398. }
  399. /// <summary>
  400. /// 连接数据库
  401. /// </summary>
  402. /// <returns>布尔值</returns>
  403. public bool connect()
  404. {
  405. try
  406. {
  407. string str1 = getConnectString();
  408. if (str1 != null)
  409. {
  410. if (oledbConn == null)
  411. {
  412. bConnectState = false;
  413. oledbConn = new OleDbConnection(str1);
  414. oledbConn.Open();
  415. if (oledbConn.State == ConnectionState.Open)
  416. {
  417. bConnectState = true;
  418. }
  419. }
  420. else
  421. {
  422. if (oledbConn.State != ConnectionState.Open)
  423. {
  424. oledbConn.Open();
  425. if (oledbConn.State == ConnectionState.Open)
  426. {
  427. bConnectState = true;
  428. }
  429. }
  430. }
  431. }
  432. else
  433. {
  434. throw new OraDBBaseException("无效的连接字符串");
  435. }
  436. }
  437. catch (System.Exception ex)
  438. {
  439. throw new OraDBBaseException(ex.Message);
  440. }
  441. return bConnectState;
  442. }
  443. /// <summary>
  444. /// 断开数据库连接
  445. /// </summary>
  446. public void disconnect()
  447. {
  448. if (oledbConn != null)
  449. {
  450. oledbConn.Close();
  451. oledbConn.Dispose();
  452. oledbConn = null;
  453. bConnectState = false;
  454. }
  455. }
  456. /// <summary>
  457. /// 执行SQL语句
  458. /// </summary>
  459. /// <param name="SQL">sql语句</param>
  460. /// <returns>布尔值</returns>
  461. public bool executeSQL(string SQL)
  462. {
  463. bool res1 = false;
  464. if (SQL == null)
  465. {
  466. throw new OraDBBaseException("无效的SQL语句");
  467. }
  468. if (oledbConn != null)
  469. {
  470. if (bConnectState)
  471. {
  472. OleDbCommand cmd1 = new OleDbCommand();
  473. cmd1.Connection = oledbConn;
  474. cmd1.CommandText = SQL;
  475. cmd1.CommandType = CommandType.Text;
  476. int num = cmd1.ExecuteNonQuery();
  477. if (num > 0)
  478. {
  479. res1 = true;
  480. }
  481. cmd1.Dispose();
  482. }
  483. else
  484. {
  485. throw new OraDBBaseException("数据库连接没有成功");
  486. }
  487. }
  488. return res1;
  489. }
  490. /// <summary>
  491. /// 获得用户的所有的表名
  492. /// </summary>
  493. /// <returns>链表值</returns>
  494. public List<string> getTables()
  495. {
  496. List<string> arr1 = new List<string>();
  497. if (oledbConn != null)
  498. {
  499. OleDbCommand cmd1 = new OleDbCommand();
  500. cmd1.Connection = oledbConn;
  501. cmd1.CommandText = string.Format("select TABLE_NAME from USER_TABLES order by TABLE_NAME");
  502. cmd1.CommandType = CommandType.Text;
  503. OleDbDataReader rd1 = cmd1.ExecuteReader();
  504. while (rd1.Read())
  505. {
  506. for (int i = 0; i < rd1.FieldCount; i++)
  507. {
  508. arr1.Add(rd1[i].ToString());
  509. }
  510. }
  511. rd1.Close();
  512. rd1.Dispose();
  513. cmd1.Dispose();
  514. }
  515. return arr1;
  516. }
  517. /// <summary>
  518. /// 获得指定的表的所有字段名
  519. /// </summary>
  520. /// <param name="Table">表</param>
  521. /// <returns>链表值</returns>
  522. public List<string> getTableColumns(string Table)
  523. {
  524. List<string> arr1 = new List<string>();
  525. try
  526. {
  527. if (oledbConn != null)
  528. {
  529. OleDbCommand cmd1 = new OleDbCommand();
  530. cmd1.Connection = oledbConn;
  531. cmd1.CommandText = $"select t.COLUMN_NAME from USER_TAB_COLUMNS t where t.TABLE_NAME='{Table.ToUpper()}'";
  532. cmd1.CommandType = CommandType.Text;
  533. OleDbDataReader rd1 = cmd1.ExecuteReader();
  534. while (rd1.Read())
  535. {
  536. for (int i = 0; i < rd1.FieldCount; i++)
  537. {
  538. Console.WriteLine(rd1[i].ToString());
  539. arr1.Add(rd1[i].ToString());
  540. }
  541. }
  542. rd1.Close();
  543. rd1.Dispose();
  544. cmd1.Dispose();
  545. }
  546. }
  547. catch (System.Exception ex)
  548. {
  549. string error = ex.ToString();
  550. }
  551. finally
  552. {
  553. }
  554. return arr1;
  555. }
  556. /// <summary>
  557. /// 获得指定的表的所有数据
  558. /// </summary>
  559. /// <param name="Table">表</param>
  560. /// <returns>数组链表值</returns>
  561. public List<string[]> getTableValues(string Table)
  562. {
  563. return selectTableValues(getSelectString2(Table));
  564. }
  565. /// <summary>
  566. /// 执行查询SQL语句
  567. /// </summary>
  568. /// <param name="SQL">sql语句</param>
  569. /// <returns>数组链表值</returns>
  570. public List<string[]> selectSQL(string SQL)
  571. {
  572. List<string[]> m1 = new List<string[]>();
  573. if (oledbConn != null)
  574. {
  575. if (bConnectState)
  576. {
  577. OleDbCommand cmd1 = new OleDbCommand();
  578. cmd1.Connection = oledbConn;
  579. cmd1.CommandText = SQL;
  580. cmd1.CommandType = CommandType.Text;
  581. OleDbDataReader rd1 = cmd1.ExecuteReader();
  582. while (rd1.Read())
  583. {
  584. string[] arr1 = new string[rd1.FieldCount];
  585. for (int i = 0; i < rd1.FieldCount; i++)
  586. {
  587. arr1[i] = rd1[i].ToString();
  588. }
  589. m1.Add(arr1);
  590. }
  591. rd1.Close();
  592. rd1.Dispose();
  593. cmd1.Dispose();
  594. }
  595. else
  596. {
  597. throw new OraDBBaseException("数据库连接没有成功");
  598. }
  599. }
  600. return m1;
  601. }
  602. /// <summary>
  603. /// 执行查询SQL语句
  604. /// </summary>
  605. /// <param name="SQL">sql语句</param>
  606. /// <returns>记录集</returns>
  607. public DataSet selectSQL3(string SQL)
  608. {
  609. DataSet ds = new DataSet();
  610. if (oledbConn != null)
  611. {
  612. if (bConnectState)
  613. {
  614. OleDbDataAdapter da = new OleDbDataAdapter(SQL, oledbConn);
  615. int m = da.Fill(ds);
  616. }
  617. else
  618. {
  619. throw new OraDBBaseException("数据库连接没有成功");
  620. }
  621. }
  622. return ds;
  623. }
  624. /// <summary>
  625. /// 查询记录的个数
  626. /// </summary>
  627. /// <param name="SQL">sql语句</param>
  628. /// <returns></returns>
  629. public int selectSQL2(string SQL)
  630. {
  631. int num = 0;
  632. if (oledbConn != null)
  633. {
  634. if (bConnectState)
  635. {
  636. OleDbCommand cmd1 = new OleDbCommand();
  637. cmd1.Connection = oledbConn;
  638. cmd1.CommandText = SQL;
  639. cmd1.CommandType = CommandType.Text;
  640. OleDbDataReader rd1 = cmd1.ExecuteReader();
  641. while (rd1.Read())
  642. {
  643. num++;
  644. }
  645. rd1.Close();
  646. rd1.Dispose();
  647. cmd1.Dispose();
  648. }
  649. else
  650. {
  651. throw new OraDBBaseException("数据库连接没有成功");
  652. }
  653. }
  654. return num;
  655. }
  656. /// <summary>
  657. /// 执行指定的查询语句
  658. /// </summary>
  659. /// <param name="SQL">sql语句</param>
  660. /// <returns>数组链表值</returns>
  661. public List<string[]> selectTableValues(string SQL)
  662. {
  663. return selectSQL(SQL);
  664. }
  665. /// <summary>
  666. /// 查询指定的表的所有数据
  667. /// </summary>
  668. /// <param name="Table">表</param>
  669. /// <returns>数组链表值</returns>
  670. public List<string[]> selectTable(string Table)
  671. {
  672. return selectSQL(getSelectString2(Table));
  673. }
  674. /// <summary>
  675. /// 执行指定表的有条件的查询语句
  676. /// </summary>
  677. /// <param name="Table">表</param>
  678. /// <param name="arrFieldAndValue">条件字段和值</param>
  679. /// <returns>数组链表值</returns>
  680. public List<string[]> selectTable(string Table, string[,] arrFieldAndValue)
  681. {
  682. return selectSQL(getSelectString(Table, arrFieldAndValue));
  683. }
  684. /// <summary>
  685. /// 执行指定表的有条件的查询语句
  686. /// </summary>
  687. /// <param name="Table">表</param>
  688. /// <param name="arrField">字段</param>
  689. /// <param name="arrValue">值</param>
  690. /// <returns>数组链表</returns>
  691. public List<string[]> selectTable(string Table, string[] arrField, string[] arrValue)
  692. {
  693. return selectSQL(getSelectString(Table, arrField, arrValue));
  694. }
  695. /// <summary>
  696. /// 执行指定表的有条件的查询语句
  697. /// </summary>
  698. /// <param name="Table">表</param>
  699. /// <param name="arrField">字段</param>
  700. /// <param name="arrValue">值</param>
  701. /// <returns>记录集</returns>
  702. public DataSet selectTable2(string Table, string[] arrField, string[] arrValue)
  703. {
  704. return selectSQL3(getSelectString(Table, arrField, arrValue));
  705. }
  706. /// <summary>
  707. /// 执行无条件的指定字段的查询语句
  708. /// </summary>
  709. /// <param name="Table">表</param>
  710. /// <param name="arrField">字段</param>
  711. /// <returns>数组链表</returns>
  712. public List<string[]> selectTable(string Table, string[] arrField)
  713. {
  714. return selectSQL(getSelectString(Table, arrField));
  715. }
  716. /// <summary>
  717. /// 执行插入语句
  718. /// </summary>
  719. /// <param name="SQL">sql语句</param>
  720. /// <returns>布尔值</returns>
  721. public bool insertSQL(string SQL)
  722. {
  723. return executeSQL(SQL);
  724. }
  725. /// <summary>
  726. /// 执行指定表的指定字段的指定值的插入语句
  727. /// </summary>
  728. /// <param name="Table">表</param>
  729. /// <param name="arrField">字段</param>
  730. /// <param name="arrValue">值</param>
  731. /// <returns>布尔值</returns>
  732. public bool insertSQL(string Table, string[] arrField, string[] arrValue)
  733. {
  734. return insertSQL(getInsertString(Table, arrField, arrValue));
  735. }
  736. /// <summary>
  737. /// 检查记录然后执行指定表的指定字段的指定值的插入语句
  738. /// </summary>
  739. /// <param name="Table">表名</param>
  740. /// <param name="arrField">字段</param>
  741. /// <param name="arrValue">值</param>
  742. /// <returns></returns>
  743. public bool insertSQLWithCheck(string Table, string[] arrField, string[] arrValue)
  744. {
  745. if (checkSQL(Table, arrField, arrValue))
  746. {
  747. return false;
  748. }
  749. return insertSQL(getInsertString(Table, arrField, arrValue));
  750. }
  751. /// <summary>
  752. /// 执行指定表的指定字段的指定值的插入语句
  753. /// </summary>
  754. /// <param name="Table">表</param>
  755. /// <param name="FieldValue">字段和值</param>
  756. /// <returns>布尔值</returns>
  757. public bool insertSQL(string Table, string[,] FieldValue)
  758. {
  759. return insertSQL(getInsertString(Table, FieldValue));
  760. }
  761. /// <summary>
  762. /// 检查记录然后执行指定表的指定字段的指定值的插入语句
  763. /// </summary>
  764. /// <param name="Table">表名</param>
  765. /// <param name="FieldValue">字段和值</param>
  766. /// <returns></returns>
  767. public bool insertSQLWithCheck(string Table, string[,] arrFieldValue)
  768. {
  769. if (checkSQL(Table, arrFieldValue))
  770. {
  771. return false;
  772. }
  773. return insertSQL(getInsertString(Table, arrFieldValue));
  774. }
  775. /// <summary>
  776. /// 先检查表中是否有记录,有记录则删除记录,然后插入记录
  777. /// </summary>
  778. /// <param name="Table">表名</param>
  779. /// <param name="arrField">字段</param>
  780. /// <param name="arrValue">值</param>
  781. /// <returns></returns>
  782. public bool insertSQLWithDelete(string Table, string[] arrField, string[] arrValue)
  783. {
  784. if (checkSQL(Table, arrField, arrValue))
  785. {
  786. deleteSQL(Table, arrField, arrValue);
  787. }
  788. return insertSQL(getInsertString(Table, arrField, arrValue));
  789. }
  790. /// <summary>
  791. /// 先检查表中是否有记录,有记录则删除记录,然后插入记录
  792. /// </summary>
  793. /// <param name="Table">表名</param>
  794. /// <param name="arrFieldValue">字段和值</param>
  795. /// <returns></returns>
  796. public bool insertSQLWithDelete(string Table, string[,] arrFieldValue)
  797. {
  798. if (checkSQL(Table, arrFieldValue))
  799. {
  800. deleteSQL(Table, arrFieldValue);
  801. }
  802. return insertSQL(getInsertString(Table, arrFieldValue));
  803. }
  804. /// <summary>
  805. /// 执行指定的表全字段的所有值的插入语句
  806. /// </summary>
  807. /// <param name="Table"></param>
  808. /// <param name="arrValue"></param>
  809. /// <returns>布尔值</returns>
  810. public bool insertSQL(string Table, string[] arrValue)
  811. {
  812. return insertSQL(getInsertString(Table, arrValue));
  813. }
  814. /// <summary>
  815. /// 执行删除语句
  816. /// </summary>
  817. /// <param name="SQL">sql语句</param>
  818. /// <returns>布尔值</returns>
  819. public bool deleteSQL2(string SQL)
  820. {
  821. return executeSQL(SQL);
  822. }
  823. /// <summary>
  824. /// 执行指定表的指定字段的指定值的删除语句
  825. /// </summary>
  826. /// <param name="Table">表</param>
  827. /// <param name="Field">条件字段</param>
  828. /// <param name="Value">条件值</param>
  829. /// <returns>布尔值</returns>
  830. public bool deleteSQL(string Table, string Field, string Value)
  831. {
  832. return deleteSQL2(getDeleteString(Table, Field, Value));
  833. }
  834. /// <summary>
  835. /// 执行指定表的指定字段的指定值的删除语句
  836. /// </summary>
  837. /// <param name="Table">表名</param>
  838. /// <param name="arrField">条件字段</param>
  839. /// <param name="arrValue">条件值</param>
  840. /// <returns></returns>
  841. public bool deleteSQL(string Table, string[] arrField, string[] arrValue)
  842. {
  843. return deleteSQL2(getDeleteString(Table, arrField, arrValue));
  844. }
  845. /// <summary>
  846. /// 执行指定表的指定字段的指定值的删除语句
  847. /// </summary>
  848. /// <param name="Table">表名</param>
  849. /// <param name="arrFieldAndValue">条件字段和值</param>
  850. /// <returns></returns>
  851. public bool deleteSQL(string Table, string[,] arrFieldAndValue)
  852. {
  853. return deleteSQL2(getDeleteString(Table, arrFieldAndValue));
  854. }
  855. /// <summary>
  856. /// 执行指定表的所有数据的删除语句
  857. /// </summary>
  858. /// <param name="Table">表</param>
  859. /// <returns>布尔值</returns>
  860. public bool deleteSQL(string Table)
  861. {
  862. return deleteSQL2(getDeleteString(Table));
  863. }
  864. /// <summary>
  865. /// 执行表的删除表语句
  866. /// </summary>
  867. /// <param name="SQL">sql语句</param>
  868. /// <returns>布尔值</returns>
  869. public bool dropSQL2(string SQL)
  870. {
  871. return executeSQL(SQL);
  872. }
  873. /// <summary>
  874. /// 执行指定表的删除表语句
  875. /// </summary>
  876. /// <param name="Table">表</param>
  877. /// <returns>布尔值</returns>
  878. public bool dropSQL(string Table)
  879. {
  880. return dropSQL2(getDeleteString(Table));
  881. }
  882. /// <summary>
  883. /// 执行创建表语句
  884. /// </summary>
  885. /// <param name="SQL">sql语句</param>
  886. /// <returns>布尔值</returns>
  887. public bool createSQL(string SQL)
  888. {
  889. return executeSQL(SQL);
  890. }
  891. /// <summary>
  892. /// 执行指定字段和类型的创建表语句
  893. /// </summary>
  894. /// <param name="Table">表</param>
  895. /// <param name="FieldAndType">字段和类型</param>
  896. /// <returns>布尔值</returns>
  897. public bool createSQL(string Table, string[,] FieldAndType)
  898. {
  899. return createSQL(getCreateString(Table, FieldAndType));
  900. }
  901. /// <summary>
  902. /// 执行更新表语句
  903. /// </summary>
  904. /// <param name="SQL"></param>
  905. /// <returns>布尔值</returns>
  906. public bool updateSQL(string SQL)
  907. {
  908. return executeSQL(SQL);
  909. }
  910. /// <summary>
  911. /// 执行指定表的指定字段的指定条件的更新语句
  912. /// </summary>
  913. /// <param name="Table">表</param>
  914. /// <param name="FieldAndNewValue">新的字段和值</param>
  915. /// <param name="FieldAndOldValue">条件字段和值</param>
  916. /// <returns>布尔值</returns>
  917. public bool updateSQL(string Table, string[,] FieldAndNewValue, string[,] FieldAndOldValue)
  918. {
  919. return updateSQL(getUpdateString(Table, FieldAndNewValue, FieldAndOldValue));
  920. }
  921. /// <summary>
  922. /// 指定字段指定值的记录在指定的表中是否有记录
  923. /// </summary>
  924. /// <param name="Table">表名</param>
  925. /// <param name="arrField">条件字段</param>
  926. /// <param name="arrValue">条件值</param>
  927. /// <returns></returns>
  928. public bool checkSQL(string Table, string[] arrField, string[] arrValue)
  929. {
  930. int n = selectSQL2(getSelectString(Table, arrField, arrValue));
  931. return n > 0 ? true : false;
  932. }
  933. /// <summary>
  934. /// 指定字段指定值的记录在指定的表中是否有记录
  935. /// </summary>
  936. /// <param name="Table">表名</param>
  937. /// <param name="arrFieldAndValue">条件字段和值</param>
  938. /// <returns></returns>
  939. public bool checkSQL(string Table, string[,] arrFieldAndValue)
  940. {
  941. int n = selectSQL2(getSelectString(Table, arrFieldAndValue));
  942. return n > 0 ? true : false;
  943. }
  944. }
  945. public class OraDBBaseException : ApplicationException
  946. {
  947. public OraDBBaseException(string msg)
  948. : base(msg)
  949. {
  950. }
  951. public override string Message
  952. {
  953. get
  954. {
  955. return base.Message;
  956. }
  957. }
  958. }
  959. }