PHP调用Oracle函数执行SQL无结果,求排查问题
问题
我希望编写一个PHP函数来执行不同的SQL查询并返回结果,该函数需支持解析、执行多种查询并从数据库获取数据。已成功通过oci_connect建立Oracle数据库连接,但编写的oracle_test函数执行查询后无结果返回,相关代码如下:
连接代码
$conn = oci_connect("{$username}", "{$password}", "{$db}"); if (!$conn) { $e=oci_error(); trigger_error(htmlentities($e['message'], ENT_QUOTES), E_USER_ERROR); } else { echo "Success"; }
函数及调用代码
function oracle_test($stmt) { global $conn; global $sth; $sth = oci_parse($conn, $stmt); oci_execute($sth, OCI_DEFAULT); return $conn->oci_fetch_array($sth, OCI_ASSOC); } $sql = "select movie, title from schema.movies"; $mov2 = oracle_test($sql); foreach ($mov2 as $row) { echo $row['MOVIE'] . $row['TITLE']; }
问题分析与修复
你的代码存在几个关键问题,导致无结果返回:
- 错误的fetch调用方式:OCI8扩展中,
oci_fetch_array是过程式函数,不是连接对象的方法,不能用$conn->oci_fetch_array()调用,正确写法是oci_fetch_array($sth, OCI_ASSOC)。 - 仅返回单行数据:
oci_fetch_array()每次调用只返回查询结果的一行,你的函数直接返回这一行,后续foreach遍历的是这一行的列(比如MOVIE和TITLE两个字段),而不是多行数据,自然得不到预期的多行输出。 - 不必要的全局变量:全局变量
$sth完全没必要,函数内部声明局部变量即可,避免全局污染。
修复后的代码
方式1:循环获取所有行
function oracle_test($stmt) { global $conn; // 用局部变量替代全局$sth $sth = oci_parse($conn, $stmt); oci_execute($sth); // 查询用默认模式即可,无需OCI_DEFAULT $result = []; // 循环获取每一行,存入数组 while ($row = oci_fetch_array($sth, OCI_ASSOC)) { $result[] = $row; } // 释放语句资源 oci_free_statement($sth); return $result; } $sql = "select movie, title from schema.movies"; $mov2 = oracle_test($sql); // 遍历每一行数据 foreach ($mov2 as $row) { echo $row['MOVIE'] . ' ' . $row['TITLE'] . '<br>'; }
方式2:用oci_fetch_all一次性获取所有结果
如果数据量不大,也可以用oci_fetch_all直接把结果转成二维数组:
function oracle_test($stmt) { global $conn; $sth = oci_parse($conn, $stmt); oci_execute($sth); $result = []; // 一次性获取所有结果到$result数组 oci_fetch_all($sth, $result, 0, -1, OCI_FETCHSTATEMENT_BY_ROW); oci_free_statement($sth); return $result; } // 调用和遍历代码和方式1一致 $sql = "select movie, title from schema.movies"; $mov2 = oracle_test($sql); foreach ($mov2 as $row) { echo $row['MOVIE'] . ' ' . $row['TITLE'] . '<br>'; }
额外说明
OCI_DEFAULT模式主要用于事务控制(比如需要手动commit/rollback),普通查询用默认的OCI_COMMIT_ON_SUCCESS即可,不需要额外指定。- 记得在完成查询后用
oci_free_statement()释放语句资源,避免内存泄漏。
内容的提问来源于stack exchange,提问作者Ronald
相关产品推荐
相关产品推荐

