001 package com.rain;
002
003 import java.sql.*;
004 import java.lang.*;
005
006 /**
007 * MYSQL 데이타 베이스 관리
008 * @version 1.0
009 * @author http://cafen.net (outmind@cafen.net)
010 */
011 public class rainMysql {
012
013 private String drivers = "org.gjt.mm.mysql.Driver";
014
015 /**
016 * 데이타 베이스 정보
017 */
018 private rainProperties database_info = null ;
019
020 /**
021 * 현재 접근된 포인터
022 */
023 private Connection current_connect = null ;
024
025 /**
026 * 마지막 오류 메세지
027 */
028 public String error_msg = "";
029
030 /**
031 * 생성자
032 * @param db_id 데이타 베이스 환경 파일 아이디 (conf/db_아이디.ini) 파일이 저장되어 있어야함)
033 */
034 public rainMysql(String db_id) {
035 this.database_info = new rainProperties("db_" + db_id);
036 }
037
038 /**
039 * 데이타 베이스 연결
040 * @return 연결 성공여부
041 */
042 public boolean connect() {
043 if (this.current_connect == null) {
044 try {
045 Class.forName(this.drivers).newInstance();
046 this.current_connect = DriverManager.getConnection(
047 "jdbc:mysql://"+this.database_info.get("host")+"/" +this.database_info.get("database") + "?autoReconnect=true&useUnicode=true&characterEncoding=euckr",
048 this.database_info.get("user"),
049 this.database_info.get("passwd")
050 );
051 return true;
052 } catch (Exception e) {
053 this.errorLog(e.getMessage());
054 return false;
055 }
056 } else
057 return true;
058 }
059
060 /**
061 * 데이타 베이스 접속해제
062 */
063 public void close() {
064 try {
065 if (this.current_connect !=null) this.current_connect.close();
066 } catch (Exception e) { this.errorLog(e.getMessage()); }
067 }
068
069 /**
070 * 데이타 베이스 오류 메세지(conf/error_log.txt) 에 기록됨
071 */
072 public void errorLog(String error_msg) {
073 rainUtil.errorLog(error_msg);
074 this.error_msg += error_msg;
075 }
076
077 /**
078 * 주어진 쿼리의 결과값을 가져옴
079 * @param qm 쿼리
080 */
081 public ResultSet query(String qm) {
082 return this.query(qm, false);
083 }
084
085 /**
086 * 주어진 업데이트 쿼리를 전송함 (delete, update, 기타 데이타베이스의 내용이 변경되는 쿼리만 전송)
087 * @param qm 쿼리
088 */
089 public void change(String qm) {
090 this.queryUpdate(qm, true);
091 }
092
093 /**
094 * 주어진 테이블의 주어진 칼럼명의 마지막 입력값에 1을 더해서 반환
095 * @param table_name 테이블명
096 * @param col_name 칼럼명
097 * @return 마지막 입력가능한 고유번호
098 */
099 public int getLastID(String table_name, String col_name) {
100 String last_id = this.queryOne("select max("+col_name+") +1 as last_id from "+table_name+" ");
101 if (last_id.equals("") || last_id.equals("0"))
102 return 1;
103 else
104 return Integer.parseInt(last_id);
105 }
106
107 /**
108 * 주어진 쿼리를 서버에 전송해서 결과 값을 반환함
109 * @param qm 쿼리
110 * @param scroll_concur 포인터 이동성여부
111 * @return 쿼리 결과
112 */
113 public ResultSet query(String qm, boolean scroll_concur) {
114 PreparedStatement pstmt = null;
115 ResultSet rs = null;
116 if (this.connect()) {
117 try {
118 if (scroll_concur)
119 pstmt = current_connect.prepareStatement(qm,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
120 else
121 pstmt = current_connect.prepareStatement(qm);
122 rs = pstmt.executeQuery();
123 } catch (Exception e) { this.errorLog(e.getMessage() + " / QUERY : " + qm); }
124 }
125 return rs;
126 }
127
128 /**
129 * 주어진 쿼리를 서버에 전송함
130 * @param qm 쿼리
131 * @param auto_commit 자동 commit 여부
132 */
133 public void queryUpdate(String qm, boolean auto_commit) {
134 PreparedStatement pstmt = null;
135 ResultSet rs = null;
136 if (this.connect()) {
137 try {
138 pstmt = current_connect.prepareStatement(qm);
139 pstmt.executeUpdate();
140 // if (auto_commit) current_connect.commit();
141 pstmt.close();
142 } catch (Exception e) { this.errorLog(e.getMessage() + " / QUERY : " + qm); }
143 }
144 }
145
146 /**
147 * 기 전송된 쿼리를 commit 시킴
148 */
149 public void commit() {
150 if (this.connect()) {
151 try {
152 current_connect.commit();
153 } catch (Exception e) { this.errorLog(e.getMessage()); }
154 }
155 }
156
157 /**
158 * 기 전송된 쿼리를 rollback 시킴
159 */
160 public void rollback() {
161 if (connect()) {
162 try {
163 current_connect.rollback();
164 } catch (Exception e) { this.errorLog(e.getMessage()); }
165 }
166 }
167
168 /**
169 * 주어진 쿼리의 첫번째 로우의 첫번째 필드를 반환함
170 * @param qm 쿼리
171 * @return 필드값
172 */
173 public String queryOne(String qm) {
174 ResultSet rs = this.query(qm);
175 String return_val = "";
176 try {
177 if(rs !=null && rs.next()) return_val = rs.getString(1);
178 if (return_val == null)
179 return_val = "";
180 } catch (Exception e) { this.errorLog(e.getMessage() + " / QUERY : " + qm); }
181 return return_val;
182 }
183
184 /**
185 * 주어진 쿼리로 지정한 갯수 만큼 가져옴
186 * @param qm 쿼리
187 * @param getrow 가져올 갯수
188 * @return ResultSet
189 */
190 public ResultSet queryFetchResultSet(String qm, int getrow) {
191 ResultSet rs = this.query(qm);
192 if (getrow == 1) {
193 try {
194 if(rs != null && rs.next()) return rs;
195 else return rs;
196 } catch (Exception e) { this.errorLog(e.getMessage() + " / QUERY : " + qm); }
197 }
198 return rs;
199 }
200
201 /**
202 * 주어진 쿼리로 지정한 갯수 만큼 가져옴 - rainData
203 * @param qm 쿼리
204 * @param getrow 가져올 갯수
205 * @return rainData
206 */
207 public rainData queryFetch(String qm, int getrow) {
208 return (new rainData(
209 this.queryFetchResultSet(qm,getrow)
210 ));
211 }
212
213 /**
214 * 주어진 쿼리로 첫번째 로우만 가져옴 - rainData
215 * @param qm 쿼리
216 * @return rainData
217 */
218 public rainData queryFetch(String qm) {
219 return queryFetch(qm, 1);
220 }
221
222 /**
223 * 주어진 쿼리에서 시작 시점 및 가져올 갯수를 지정해서 결과치를 가져옴
224 * @param qm 쿼리
225 * @param cline 시작위치
226 * @param row_count 가져올 갯수
227 * @return rainData
228 */
229 public rainData query2Array(String qm, int cline , int row_count) {
230 int from_pos = qm.indexOf(" from ");
231 String first_qm = "";
232 String end_qm = "";
233 ResultSet rs = null;
234 int total_rows = 0;
235 int perpage = row_count ;
236 if (from_pos > 0) {
237 first_qm = qm.substring(0, from_pos);
238 end_qm = qm.substring(from_pos + 6);
239 String count_qm = "select count(*) as row_count from " + end_qm ;
240 total_rows = Integer.parseInt(this.queryOne(count_qm));
241 cline = (cline >= total_rows) ? (total_rows - 1): cline;
242 int startnum = (int) Math.floor(cline/row_count) * row_count;
243 int endnum = ((cline + row_count) > total_rows)?total_rows:(cline + row_count);
244 int total_pages = (int) Math.ceil(total_rows/row_count);
245 int current_page = (int) Math.ceil((cline+1)/row_count);
246 int offsetnum = endnum - startnum;
247 rs = this.query(qm + " limit " +startnum + ", " + offsetnum);
248 }
249 return new rainData(rs, total_rows, perpage , cline);
250 }
251
252 }