reasonableframework/helper/database.oracle.php

<?php
/**
 * @file oracle.php
 * @date 2018-03-27
 * @author Go Namhyeon <gnh1201@gmail.com>
 * @brief Oracle database helper for ReasonableFramework
 */

if(!function_exists("get_db_orable_binded_sql")) {
	function get_db_orable_binded_sql($sql, $bind) {
		return get_db_binded_sql($sql, $bind);
	}
}

if(!function_exists("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(!function_exists("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(!function_exists("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(!function_exists("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(!function_exists($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(!function_exists("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(!function_exists("close_db_oracle_connect")) {
	function close_db_oracle_connect() {
		$dbc =  get_scope("dbc");
		return oci_close($dbc);
	}
}