OracleDynamicParameters.cs 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. using Dapper;
  2. using Oracle.ManagedDataAccess.Client;
  3. using System;
  4. using System.Collections.Generic;
  5. using System.Data;
  6. using System.Linq;
  7. using System.Threading.Tasks;
  8. namespace SuperCms.Oracle
  9. {
  10. public class OracleDynamicParameters : SqlMapper.IDynamicParameters
  11. {
  12. private static readonly log4net.ILog log = log4net.LogManager.GetLogger(typeof(OracleDynamicParameters));
  13. private readonly DynamicParameters dynamicParameters = new DynamicParameters();
  14. private readonly List<OracleParameter> oracleParameters = new List<OracleParameter>();
  15. public void Add(string name, OracleDbType oracleDbType, ParameterDirection direction, object value = null, int? size = null)
  16. {
  17. try
  18. {
  19. OracleParameter oracleParameter;
  20. if (size.HasValue)
  21. {
  22. oracleParameter = new OracleParameter(name, oracleDbType, size.Value, value, direction);
  23. }
  24. else
  25. {
  26. oracleParameter = new OracleParameter(name, oracleDbType, value, direction);
  27. }
  28. oracleParameters.Add(oracleParameter);
  29. }
  30. catch (Exception ex)
  31. {
  32. log.Error(ex);
  33. throw ex;
  34. }
  35. }
  36. public void Add(string name, OracleDbType oracleDbType, ParameterDirection direction)
  37. {
  38. try
  39. {
  40. var oracleParameter = new OracleParameter(name, oracleDbType, direction);
  41. oracleParameters.Add(oracleParameter);
  42. }
  43. catch (Exception ex)
  44. {
  45. log.Error(ex);
  46. throw ex;
  47. }
  48. }
  49. public void AddParameters(IDbCommand command, SqlMapper.Identity identity)
  50. {
  51. try
  52. {
  53. ((SqlMapper.IDynamicParameters)dynamicParameters).AddParameters(command, identity);
  54. var oracleCommand = command as OracleCommand;
  55. if (oracleCommand != null)
  56. {
  57. oracleCommand.Parameters.AddRange(oracleParameters.ToArray());
  58. }
  59. }
  60. catch (Exception ex)
  61. {
  62. log.Error(ex);
  63. throw ex;
  64. }
  65. }
  66. }
  67. }