ConnectDB.cs 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. using Oracle.ManagedDataAccess.Client;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Security.Cryptography;
  6. namespace UAS_Tools_HY.PublicMethods
  7. {
  8. internal class ConnectDB
  9. {
  10. private static readonly string ConnectionString = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=10.1.81.208)(PORT=11687))(CONNECT_DATA=(SERVICE_NAME=orcl)));User Id=N_MES_HY;Password=select!#%*(;";
  11. public static bool TestConnection()
  12. {
  13. try
  14. {
  15. using (OracleConnection connection = new OracleConnection(ConnectionString))
  16. {
  17. connection.Open();
  18. return true;
  19. }
  20. }
  21. catch (Exception ex)
  22. {
  23. throw new Exception($"数据库连接测试失败: {ex.Message}");
  24. }
  25. }
  26. public static DataTable ExecuteSelect(string sqlQuery, Dictionary<string, object> parameters = null)
  27. {
  28. DataTable dataTable = new DataTable();
  29. try
  30. {
  31. using (OracleConnection connection = new OracleConnection(ConnectionString))
  32. {
  33. connection.Open();
  34. using (OracleCommand command = new OracleCommand(sqlQuery, connection))
  35. {
  36. if (parameters != null && parameters.Count > 0)
  37. {
  38. foreach (var param in parameters)
  39. {
  40. command.Parameters.Add(new OracleParameter(param.Key, param.Value ?? DBNull.Value));
  41. }
  42. }
  43. using (OracleDataAdapter adapter = new OracleDataAdapter(command))
  44. {
  45. adapter.Fill(dataTable);
  46. }
  47. }
  48. }
  49. }
  50. catch (Exception ex)
  51. {
  52. throw new Exception(ex.Message);
  53. }
  54. return dataTable;
  55. }
  56. }
  57. }