OracleHelper.cs 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. using Oracle.ManagedDataAccess.Client;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Linq;
  6. using System.Text;
  7. namespace TimedUpload.utils
  8. {
  9. public class OracleHelper
  10. {
  11. private static string connStr = "";
  12. #region 执行SQL语句,返回受影响行数
  13. public static int ExecuteNonQuery(string sql, params OracleParameter[] parameters)
  14. {
  15. using (OracleConnection conn = new OracleConnection(connStr))
  16. {
  17. conn.Open();
  18. using (OracleCommand cmd = conn.CreateCommand())
  19. {
  20. cmd.CommandText = sql;
  21. if (parameters != null)
  22. {
  23. cmd.Parameters.AddRange(parameters);
  24. }
  25. return cmd.ExecuteNonQuery();
  26. }
  27. }
  28. }
  29. #endregion
  30. #region 执行SQL语句,返回DataTable;只用来执行查询结果比较少的情况
  31. public static DataTable ExecuteDataTable(string sql, params OracleParameter[] parameters)
  32. {
  33. using (OracleConnection conn = new OracleConnection(connStr))
  34. {
  35. conn.Open();
  36. using (OracleCommand cmd = conn.CreateCommand())
  37. {
  38. cmd.CommandText = sql;
  39. if (parameters != null)
  40. {
  41. cmd.Parameters.AddRange(parameters);
  42. }
  43. OracleDataAdapter adapter = new OracleDataAdapter(cmd);
  44. DataTable datatable = new DataTable();
  45. adapter.Fill(datatable);
  46. return datatable;
  47. }
  48. }
  49. }
  50. #endregion
  51. }
  52. }