| Index: trunk/phase3/includes/db/DatabaseOracle.php |
| — | — | @@ -970,7 +970,8 @@ |
| 971 | 971 | } |
| 972 | 972 | |
| 973 | 973 | /* defines must comply with ^define\s*([^\s=]*)\s*=\s?'\{\$([^\}]*)\}'; */ |
| 974 | | - function sourceStream( $fp, $lineCallback = false, $resultCallback = false, $fname = 'DatabaseOracle::sourceStream' ) { |
| | 974 | + function sourceStream( $fp, $lineCallback = false, $resultCallback = false, |
| | 975 | + $fname = 'DatabaseOracle::sourceStream', $inputCallback = false ) { |
| 975 | 976 | $cmd = ''; |
| 976 | 977 | $done = false; |
| 977 | 978 | $dollarquote = false; |
| — | — | @@ -1024,6 +1025,9 @@ |
| 1025 | 1026 | } |
| 1026 | 1027 | |
| 1027 | 1028 | $cmd = $this->replaceVars( $cmd ); |
| | 1029 | + if ( $inputCallback ) { |
| | 1030 | + call_user_func( $inputCallback, $cmd ); |
| | 1031 | + } |
| 1028 | 1032 | $res = $this->doQuery( $cmd ); |
| 1029 | 1033 | if ( $resultCallback ) { |
| 1030 | 1034 | call_user_func( $resultCallback, $res, $this ); |