113 lines
2.6 KiB
PHP
113 lines
2.6 KiB
PHP
<?php
|
|
/**
|
|
* @file oracle.php
|
|
* @date 2018-03-27
|
|
* @author Go Namhyeon <gnh1201@gmail.com>
|
|
* @brief Oracle database helper for ReasonableFramework
|
|
*/
|
|
|
|
if(!check_valid_function("get_db_orable_binded_sql")) {
|
|
function get_db_orable_binded_sql($sql, $bind) {
|
|
return get_db_binded_sql($sql, $bind);
|
|
}
|
|
}
|
|
|
|
if(!check_valid_function("get_db_oracle_stmt")) {
|
|
function get_db_oracle_stmt($sql, $bind) {
|
|
$stmt = NULL;
|
|
|
|
$sql = get_db_orable_binded_sql($sql, $bind);
|
|
$stmt = oci_parse($conn, $sql);
|
|
|
|
return $stmt;
|
|
}
|
|
}
|
|
|
|
if(!check_valid_function("exec_db_oracle_connect")) {
|
|
function exec_db_oracle_connect($host, $port, $user, $password, $options=array()) {
|
|
$conn = NULL;
|
|
$envs = get_value_in_array("envs", $options, array());
|
|
|
|
if(!check_valid_function("oci_connect")) {
|
|
exit("OCI (Oracle Extension for PHP) not installed!");
|
|
}
|
|
|
|
if(array_key_empty("NLS_LANG", $envs)) {
|
|
$envs["NLS_LANG"] = "KOREAN_KOREA.AL32UTF8";
|
|
}
|
|
|
|
// set environment variables
|
|
foreach($envs as $env) {
|
|
putenv($env);
|
|
}
|
|
|
|
// get oracle db connection info
|
|
$dbs_id = read_storage_file("tnsname.orax", array(
|
|
"storage_type" => "config"
|
|
));
|
|
|
|
// set replace rules
|
|
$dbs_rules = array(
|
|
"protocol" => get_value_in_array("service_name", $options, "TCP"),
|
|
"service_name" => get_value_in_array("service_name", $options, "ORCL"),
|
|
"host" => $host,
|
|
"port" => $port,
|
|
"server_type" => "DEDICATED"
|
|
);
|
|
|
|
// parse db connection info
|
|
foreach($dbs_rules as $k=>$v) {
|
|
$dbs_id = str_replace("%" . $k . "%", $v, $dbs_id);
|
|
}
|
|
|
|
// set db connection
|
|
$conn = @oci_connect($user, $password, $dbs_id);
|
|
|
|
return $conn;
|
|
}
|
|
}
|
|
|
|
if(!check_valid_function("exec_db_oracle_fetch_all")) {
|
|
function exec_db_oracle_fetch_all($sql, $bind, $conn) {
|
|
$rows = array();
|
|
|
|
$required_functions = array("oci_parse", "oci_execute", "oci_fetch_assoc", "oci_free_statement");
|
|
foreach($required_functions as $func_name) {
|
|
if(!check_valid_function($func_name)) {
|
|
exit("OCI (Oracle Extension for PHP) not installed!");
|
|
}
|
|
}
|
|
|
|
$stmt = get_db_oracle_stmt($sql, $bind);
|
|
oci_execute($stmt);
|
|
|
|
while($row = oci_fetch_assoc($stmt)) {
|
|
$rows[] = $row;
|
|
}
|
|
|
|
oci_free_statement($stmt);
|
|
|
|
return $rows;
|
|
}
|
|
}
|
|
|
|
if(!check_valid_function("exec_db_oracle_query")) {
|
|
function exec_db_oracle_query($sql, $bind, $conn) {
|
|
$flag = false;
|
|
|
|
$stmt = get_db_oracle_stmt($sql, $bind);
|
|
$flag = oci_execute($stmt);
|
|
|
|
oci_free_statement($stmt);
|
|
|
|
return $flag;
|
|
}
|
|
}
|
|
|
|
if(!check_valid_function("close_db_oracle_connect")) {
|
|
function close_db_oracle_connect() {
|
|
$dbc = get_scope("dbc");
|
|
return oci_close($dbc);
|
|
}
|
|
}
|