";	
		print_r($data);
		echo "

can't create connection

";
		$db->Connect($this->dbhost, $this->dbuser, $this->dbpassword, $this->dbname) or DIE("
can't connect to server
");
		return $db;
	}

	function _dbquery($sqlstr){
	  $recordset = $this->conn->Execute($sqlstr);
	  return $recordset;
	}

	function _dbexecquery($sqlstr, $par1=NULL){
		if($this->log_id == "" ){
			$user_id = $_SESSION["uid"];
			//$this->_getaction($method, $sub_method, $action, $user_id);
			//$this->log_id = $this->_activitylog($user_id, $method, $sub_method, $action, $sqlstr, 1);
		}
	  $recordset = $this->conn->Execute($sqlstr, $par1);
	  if(!$recordset){
	  	$error_num = $this->conn->ErrorNo();
			$error_msg = str_replace("'", " (single quote) ", $this->conn->ErrorMsg());
			DIE($this->conn->ErrorMsg());
	  	$this->RollbackTrans();
	  	$params = $sqlstr." ErrorMsg : ".$error_msg;
			//$this->_activitylog($user_id, $method, $sub_method, $action, $params, 0);
		  $href = $_SERVER["HTTP_REFERER"];
			?>
					
	  	conn->SelectLimit($sqlstr, $temp_numrows, $offset);
	  return $recordset;
	  if(!$recordset){
	  	$error_num = $this->conn->ErrorNo();
	  	$error_msg = $this->conn->ErrorMsg();
	  	$this->conn->RollbackTrans();
			?>
					
	  	conn->SelectLimit($sqlstr, $temp_numrows, $offset);
	  return $recordset;
	  if(!$recordset){
	  	$error_num = $this->conn->ErrorNo();
	  	$error_msg = $this->conn->ErrorMsg();
	  	$this->conn->RollbackTrans();
			?>
					
	  	uniqid();
		$activity_datetime = date("Y-m-d h:i:s");
		$activity_params = str_replace("\n", " ", $activity_params);
		//$activity_params = $this->parseSQL(str_replace("'", "\"", $activity_params));
		$activity_user_id = $_SESSION["uid"];
		$sql = "insert into tbl_activity_log values(
						'$activity_id',
						'$activity_user_id',
						'$activity_datetime',
						'$activity_method',
						'$activity_submethod',
						'$activity_action',
						'',
						'$activity_result'
						)";
		$this->conn->BeginTrans();
		$this->conn->Execute($sql);
		$this->conn->CommitTrans();
		return $activity_id;
	}

	function _getaction(&$method, &$sub_method, &$action, &$user_id){
		$arr_action = explode('&', $_SERVER["argv"][0]);
		$a = explode('=', $arr_action[0]);
		$method = $_REQUEST["method"];
		$a = explode('=', $arr_action[1]);
		$sub_method = $_REQUEST["submethod"];
		$action = $_REQUEST["data_action"];
		$user_id = $_SESSION["user_id"];
	}

	function uniqid(){
		$a = sha1(microtime());
		return $a;

	}

	function parseSQL($sql){
		$sql = strtoupper($sql);
		$arr = explode(" ", $sql);
		array_walk($arr, 'trim_value');
		switch($arr[0]){
			case "INSERT":
				for($i=3;$i<=count($arr);$i++) $return_str .= $arr[$i]." ";
			break;
			case "DELETE":
				$new_sql = "select * from $arr[1] ";
				$xxx = array_search("WHERE", $arr);
				for($i=$xxx;$i<=count($arr);$i++) $new_sql .= $arr[$i]." ";
				$rs = $this->conn->Execute($new_sql);
				$current_record = "";
				$deleted_record = $rs->GetRowAssoc();
				$current_arr = $rs->FetchRow();
				$current_field_count = $rs->FieldCount();
				foreach ($deleted_record as $k => $v) {
						   $current_record .= "\$deleted_record[$k] => $v;";
					}

				$return_str = $current_record;
			break;
			case "UPDATE":
				$new_sql = "select * from $arr[1] ";
				$return_str = $new_sql;
				$a = array_search("WHERE", $arr);
				for($i=$a;$iconn->Execute($new_sql);
				$current_record = "";
				$edited_record = $rs->GetRowAssoc();
				$current_arr = $rs->FetchRow();
				$current_field_count = $rs->FieldCount();
		  	foreach ($edited_record as $k => $v) {
					   $current_record .= "\$edited_record[$k] => $v;";
				}
				$sql = str_replace("\n", " ", $sql);
				$s = array_search("SET", $arr);
				for($f=($s+1);$f<$a;$f++) $a_sql .= $arr[$f]." ";
				$return_str = $a_sql."-- ".$current_record;
			break;
		}
	return $return_str;
	}
}

	function trim_value(&$value)
	{
	   $value = trim($value);
	}
?>