变更oracle访问组件

wzp

2023-03-02 374ce4ffd0c459bb4067e8d5765f972668aff9b1

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
 
using Common;
using Oracle.ManagedDataAccess.Client;
using System;
using System.Collections.Generic;
using System.Data.Common;
 
namespace Dao
{
  public class GwRptCodeDao : IDisposable
  {
    public List<RptCode> LoadRptCodeList()
    {
      List<RptCode> list = new List<RptCode>();
      using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE ORDER BY CREATE_TIME ASC", OracleHelper.Connection))
      {
        while (reader != null && ((DbDataReader) reader).Read())
        {
          OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
          list.Add(new RptCode()
          {
            NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""),
            OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""),
            CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"),
            Remark = oracleReaderWrapper.GetString("REMARK", "")
          });
        }
      }
      return list;
    }
 
    public void Dispose()
    {
    }
 
    public RptCode GetRptCode(string oldCode)
    {
      using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object) oldCode)))
      {
        if (reader != null && ((DbDataReader) reader).Read())
        {
          OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
          return new RptCode()
          {
            NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""),
            OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""),
            CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"),
            Remark = oracleReaderWrapper.GetString("REMARK", "")
          };
        }
      }
      return (RptCode) null;
    }
 
    public bool UpdateCode(RptCode code)
    {
      return OracleHelper.ExecuteSql("UPDATE GW_RPT_CODE SET NEW_CODE =:NEW_CODE,REMARK=:REMARK WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":NEW_CODE", (object) code.NewCode), new OracleParameter(":OLD_CODE", (object) code.OldCode), new OracleParameter(":REMARK", (object) code.Remark)) > 0;
    }
 
    public bool DeleteCode(string oldCode)
    {
      return OracleHelper.ExecuteSql("DELETE FROM GW_RPT_CODE WHERE OLD_CODE = :OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object) oldCode)) > 0;
    }
 
    public bool AddCode(RptCode code)
    {
      return OracleHelper.ExecuteSql("INSERT INTO GW_RPT_CODE(OLD_CODE,NEW_CODE,CREATE_TIME,REMARK) VALUES(:OLD_CODE,:NEW_CODE,SYSDATE,:REMARK)", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object) code.OldCode), new OracleParameter(":NEW_CODE", (object) code.NewCode), new OracleParameter(":REMARK", (object) code.Remark)) > 0;
    }
 
    public List<ErrCode> LoadErrCodeList()
    {
      List<ErrCode> list = new List<ErrCode>();
      using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_ERR_CODE ORDER BY TYPE,CODE ASC", OracleHelper.Connection))
      {
        while (reader != null && ((DbDataReader) reader).Read())
        {
          OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
          list.Add(new ErrCode()
          {
            Code = oracleReaderWrapper.GetString("CODE", ""),
            Remark = oracleReaderWrapper.GetString("REMARK", ""),
            Type = oracleReaderWrapper.GetInt("TYPE", 0)
          });
        }
      }
      return list;
    }
  }
}