DacPosition.cs 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Text;
  4. using System.Data;
  5. namespace FPER
  6. {
  7. public class DacPosition : DacBase
  8. {
  9. public DacPosition(int ID)
  10. : base(ID)// cyim 2015.7.30 데이타베이스 접속 루틴 변경
  11. {
  12. //try {
  13. // base.Connect();
  14. //}
  15. //catch (Exception ex) {
  16. // Util.UErrorMessage(ex, 0, 0);
  17. //}
  18. }
  19. ~DacPosition()
  20. {
  21. //try {
  22. // base.DisConnect();
  23. //}
  24. //catch (Exception ex) {
  25. // Util.UErrorMessage(ex, 0, 0);
  26. //}
  27. }
  28. public DataTable Position_Select(string POSITION_CODE)
  29. {
  30. DataTable dt = null;
  31. try
  32. {
  33. String SQL = "";
  34. if (POSITION_CODE == null)
  35. {
  36. SQL += "SELECT POSITION_CODE,POSITION_NAME ";
  37. SQL += " FROM TB_POSITION_CODE ORDER BY POSITION_CODE";
  38. }
  39. else
  40. {
  41. SQL += "SELECT POSITION_CODE,POSITION_NAME ";
  42. SQL += " FROM TB_POSITION_CODE WHERE POSITION_CODE = '{0}' ";
  43. SQL = String.Format(SQL, POSITION_CODE);
  44. }
  45. DataSet dao = Select(SQL);
  46. dt = dao.Tables[0];
  47. }
  48. catch (Exception ex)
  49. {
  50. Util.UErrorMessage(ex, 0, 0);
  51. throw ex;
  52. }
  53. return dt;
  54. }
  55. public void Position_Update(QUERYMode cmd, String POSITION_CODE, String POSITION_NAME)
  56. {
  57. try
  58. {
  59. DataTable dt = Position_Select(POSITION_CODE);
  60. if (cmd == QUERYMode.insert || cmd == QUERYMode.update || cmd == QUERYMode.InsertAndUpdate)
  61. {
  62. String SQL = "";
  63. if (dt.Rows.Count > 0)
  64. {
  65. SQL = "UPDATE TB_POSITION_CODE SET POSITION_NAME = '{0}'";
  66. SQL += ", UPDATE_USER_ID = 'FPER', UPDATE_TIME = current_timestamp";
  67. SQL += " WHERE POSITION_CODE = '{1}'";
  68. SQL = String.Format(SQL, POSITION_NAME, POSITION_CODE);
  69. }
  70. else
  71. {
  72. SQL = "INSERT INTO TB_POSITION_CODE ( ";
  73. SQL += " POSITION_CODE,POSITION_NAME";
  74. SQL += ",UPDATE_USER_ID,UPDATE_TIME";
  75. SQL += ") VALUES ('{0}','{1}','FPER',current_timestamp)";
  76. SQL = String.Format(SQL, POSITION_CODE, POSITION_NAME);
  77. }
  78. ExecuteNonQuery(SQL);
  79. }
  80. else if (cmd == QUERYMode.delete)
  81. {
  82. if (dt.Rows.Count < 1)
  83. {
  84. throw new Exception("해당 자료를 찾을수 없습니다.");
  85. }
  86. String SQL = "DELETE FROM TB_POSITION_CODE WHERE POSITION_CODE = '{0}'";
  87. SQL = String.Format(SQL, POSITION_CODE);
  88. ExecuteNonQuery(SQL);
  89. }
  90. }
  91. catch (Exception ex)
  92. {
  93. Util.UErrorMessage(ex, 0, 0);
  94. throw ex;
  95. }
  96. }
  97. public void PositionCode_Clear()
  98. {
  99. try
  100. {
  101. String SQL = "DELETE FROM TB_POSITION_CODE ";
  102. ExecuteNonQuery(SQL);
  103. }
  104. catch (Exception ex)
  105. {
  106. Util.UErrorMessage(ex, 0, 0);
  107. throw ex;
  108. }
  109. }
  110. }
  111. }