File Source for rainMysql.php

<?
/**
* MYSQL 데이타 베이스 관리
* @package com.rain
* @version 1.0
* @author http://cafen.net (outmind@cafen.net)
*/
class rainMysql {
/**
* 데이타 베이스 정보
*
* @var Array
*/
var $database_info = null ;
/**
* 현재 컨넥션
*
* @var resource
*/
var $current_connect = null ;
/**
* 마지막 오류 메세지
*
* @var String
*/
var $error_msg = "";
/**
* 생성자
* @param String 데이타 베이스 환경 파일 아이디 (conf/db_아이디.ini) 파일이 저장되어 있어야함)
*/
function rainMysql($db_id) {
$this->database_info = new rainProperties("db_" . $db_id);
}
/**
* 데이타 베이스 연결
*
* @return Boolean 연결 성공여부
*/
function connect() {
if ($this->current_connect == null) {
$this -> current_connect = @mysql_connect(
$this -> database_info -> get('host'),
$this -> database_info -> get('user'),
$this -> database_info -> get('passwd'), true);
if ($this -> current_connect == 0) {
$this -> errorLog('Error : Login');
} else {
$database = $this -> database_info -> get('database');
if ($database != '' &&
!@mysql_select_db($database,$this -> current_connect)) {
$this -> errorLog('Error : DataBase');
}
}
}
if ($this->current_connect == null || $this -> current_connect == 0)
return false;
else
return true;
}
/**
* 데이타 베이스 접속해제
*/
function close() {
if ($this -> current_connect != 0) @mysql_close($this -> current_connect);
}
/**
* 데이타 베이스 오류 메세지(conf/error_log.txt) 에 기록됨
*
* @param String 오류메세지
*/
function errorLog($error_msg) {
rainUtil::errorLog($error_msg);
$this->error_msg .= $error_msg;
}
/**
* 주어진 업데이트 쿼리를 전송함 (delete, update, 기타 데이타베이스의 내용이 변경되는 쿼리만 전송)
*
* @param String 쿼리
*/
function change($qm) {
$this->queryUpdate($qm, true);
}
/**
* 주어진 테이블의 주어진 칼럼명의 마지막 입력값에 1을 더해서 반환
*
* @param String 테이블명
* @param String 칼럼명
* @return Int 마지막 입력가능한 고유번호
*/
function getLastID($table_name, $col_name) {
$last_id = $this->queryOne("select max(" . $col_name . ") +1 as last_id from " . $table_name . " ");
if ($last_id == '' || $last_id == '0')
return 1;
else
return intval($last_id);
}
/**
* 주어진 쿼리를 서버에 전송해서 결과 값을 반환함
*
* @param String 쿼리
* @param Boolean 포인터 이동성여부
* @return resource 쿼리 결과
*/
function query($qm, $scroll_concur = false) {
if ($this->connect()) {
if ($this -> last_query_result) {
@mysql_free_result($this -> last_query_result);
$this -> last_query_result = null;
}
if (!($this -> last_query_result = @mysql_query($qm, $this -> current_connect)))
$this -> errorLog('Error : query Error '.$qm);
return $this -> last_query_result;
} else
return false;
}
/**
* 주어진 쿼리를 서버에 전송함
*
* @param String 쿼리
* @param Boolean 자동 commit 여부
*/
function queryUpdate($qm, $auto_commit) {
$this->query($qm, true);
}
/**
* 기 전송된 쿼리를 commit 시킴
*/
function commit() { }
/**
* 기 전송된 쿼리를 rollback 시킴
*/
function rollback() { }
/**
* 주어진 쿼리의 첫번째 로우의 첫번째 필드를 반환함
*
* @param String 쿼리
* @return String 필드값
*/
function queryOne($qm) {
$rs = $this->query($qm);
$return_val = Array();
if($rs && $return_val = @mysql_fetch_array($rs))
return $return_val[0];
else
return '';
}
/**
* 주어진 쿼리로 지정한 갯수 만큼 가져옴
*
* @param String 쿼리
* @param Int 가져올 갯수
* @return resource ResultSet
*/
function queryFetchResultSet($qm, $getrow) {
$rs = $this->query($qm);
return $rs;
}
/**
* 주어진 쿼리로 지정한 갯수 만큼 가져옴 - rainData
*
* @param String 쿼리
* @param Int 가져올 갯수
* @return rainData
*/
function queryFetch($qm, $getrow = 1) {
return (new rainData(
new rainMysqlResultSet($this->queryFetchResultSet($qm,$getrow))
));
}
/**
* 주어진 쿼리에서 시작 시점 및 가져올 갯수를 지정해서 결과치를 가져옴
*
* @param String 쿼리
* @param Int 시작위치
* @param Int 가져올 갯수
* @return rainData
*/
function query2Array($qm, $cline , $row_count) {
$from_pos = strpos($qm," from ", 5);
$first_qm = "";
$end_qm = "";
$rs = null;
$total_rows = 0;
$perpage = $row_count ;
if ($from_pos > 0) {
$first_qm = substr($qm,0, $from_pos);
$end_qm = substr($qm,$from_pos + 6);
$count_qm = "select count(*) as row_count from " . $end_qm ;
$total_rows = intval($this->queryOne($count_qm));
$cline = ($cline >= $total_rows) ? ($total_rows - 1): $cline;
$startnum = floor($cline/$row_count) * $row_count;
$endnum = (($cline + $row_count) > $total_rows) ? $total_rows:($cline + $row_count);
$total_pages = ceil($total_rows/$row_count);
$current_page = ceil(($cline+1)/$row_count);
$offsetnum = $endnum - $startnum;
$rs = $this->query($qm . " limit " . $startnum . ", " . $offsetnum);
}
return new rainData(new rainMysqlResultSet($rs), $total_rows, $perpage , $cline);
}
}
/**
* MYSQL ResultRest 관리
* @package com.rain
* @version 1.0
* @author http://cafen.net (outmind@cafen.net)
*/
class rainMysqlResultSet {
/**
* 대상 ResultSet
*
* @var resource
*/
var $resultset = null;
/**
* 생성자
*
* @param resource ResultSet
*/
function rainMysqlResultSet($resultset) {
$this->resultset = $resultset;
}
/**
* 대상 Record 수 가져오기
*
* @return Int 레코드 수
*/
function num_rows() {
return @mysql_num_rows($this->resultset);
}
/**
* 대상 Record 포인터 이동
*
* @param Int 이동할 포인터번호
*/
function field_seek($row) {
@mysql_field_seek($this->resultset, $row);
}
/**
* 현재 포인터의 레코드를 Array 로 전환
*
* @return Array
*/
function fetch_array() {
return @mysql_fetch_array($this->resultset, MYSQL_BOTH);
}
}
?>

Source for file rainMysql.php