@- Added temporary LOB support in OCI8 (Patch by David Benson)

diff --git a/ext/oci8/CREDITS b/ext/oci8/CREDITS
index 528ae1c795b024c9748ce5b36f674e075c72c4a9..30c88be459209753cadfd08d8e5ad799aa2384e8 100644 (file)
--- a/ext/oci8/CREDITS
+++ b/ext/oci8/CREDITS
@@ -1,2 +1,2 @@
 OCI8
-Stig Bakken, Thies C. Arntzen, Andy Sautins
+Stig Bakken, Thies C. Arntzen, Andy Sautins, David Benson

diff --git a/ext/oci8/oci8.c b/ext/oci8/oci8.c
index 4342af429b6e9c06241e3120ce81514683a248cb..5e6e48008d00d203607fed93877afdc58bc5c69f 100644 (file)
--- a/ext/oci8/oci8.c
+++ b/ext/oci8/oci8.c
@@ -16,6 +16,7 @@
    |          Thies C. Arntzen <thies@thieso.net>                                                |
    |                                                                                                                                     |
    | Collection support by Andy Sautins <asautins@veripost.net>           |
+   | Temporary LOB support by David Benson <dbenson@mancala.com>                 |
    +----------------------------------------------------------------------+
  */
 
@@ -51,10 +52,9 @@
 /* {{{ includes & stuff */
 
 #include "php.h"
-
-#include "ext/standard/head.h"
 #include "ext/standard/info.h"
 
+/* #define WITH_TEMP_LOBS 1 */
 #define WITH_COLLECTIONS 1
 
 #if HAVE_OCI8
@@ -209,6 +209,10 @@ PHP_FUNCTION(ociserverversion);
 PHP_FUNCTION(ocistatementtype);
 PHP_FUNCTION(ocirowcount);
 PHP_FUNCTION(ocisetprefetch);
+#ifdef WITH_TEMP_LOBS
+PHP_FUNCTION(ociwritetemporarylob);
+PHP_FUNCTION(ocicloselob);
+#endif
 #ifdef WITH_COLLECTIONS
 PHP_FUNCTION(ocinewcollection);
 PHP_FUNCTION(ocifreecoll);
@@ -324,6 +328,10 @@ static zend_function_entry php_oci_functions[] = {
 static zend_function_entry php_oci_lob_class_functions[] = {
     PHP_FALIAS(load,       ociloadlob,       NULL)
     PHP_FALIAS(writetofile,    ociwritelobtofile,NULL)
+#ifdef WITH_TEMP_LOBS
+    PHP_FALIAS(writetemporary, ociwritetemporarylob,NULL)
+    PHP_FALIAS(close,          ocicloselob,      NULL)
+#endif
     PHP_FALIAS(save,       ocisavelob,       NULL)
     PHP_FALIAS(savefile,    ocisavelobfile,   NULL)
     PHP_FALIAS(free,       ocifreedesc,      NULL)
@@ -3174,6 +3182,151 @@ PHP_FUNCTION(ociwritelobtofile)
 }
 /* }}} */
 
+#ifdef WITH_TEMP_LOBS
+/* {{{ proto int ociwritetemporarylob(int stmt, int loc, string var)
+   Return the row count of an OCI statement */
+
+PHP_FUNCTION(ociwritetemporarylob)
+{
+    zval *id, **var;
+       OCILobLocator *mylob;
+       oci_connection *connection;
+       oci_descriptor *descr;
+       ub4 offset = 1;
+       ub4 loblen;
+
+    oci_debug ("oci_write_temporary_lob");
+
+       if ((id = getThis()) == 0) {
+        RETURN_FALSE;
+    }
+
+    if (_oci_get_ocidesc(id,&descr) == 0) {
+        RETURN_FALSE;
+    }
+
+    mylob = (OCILobLocator *) descr->ocidescr;
+
+    if (! mylob) {
+        RETURN_FALSE;
+    }
+
+    connection = descr->conn;
+
+    if (zend_get_parameters_ex(1, &var) == FAILURE) {
+        WRONG_PARAM_COUNT;
+    }
+
+    convert_to_string_ex(var);
+    
+    connection->error = 
+        OCILobCreateTemporary(connection->pServiceContext,
+                              connection->pError,
+                              mylob,
+                              OCI_DEFAULT,
+                              OCI_DEFAULT,
+                              OCI_TEMP_CLOB,
+                              TRUE,
+                              OCI_DURATION_SESSION);
+
+    if (connection->error) {
+        oci_error(connection->pError, "OCILobCreateTemporary", connection->error);
+        oci_handle_error(connection, connection->error);
+        RETURN_FALSE;
+    }
+
+    connection->error = 
+        OCILobOpen(connection->pServiceContext,
+                   connection->pError,
+                   mylob,
+                   OCI_LOB_READWRITE);
+
+    if (connection->error) {
+        oci_error(connection->pError, "OCILobOpen", connection->error);
+        oci_handle_error(connection, connection->error);
+        RETURN_FALSE;
+    }
+
+    convert_to_string_ex(var);
+    loblen = (*var)->value.str.len;
+       
+    if (loblen < 1) {
+        php_error(E_WARNING, "Cannot save a lob wich size is less than 1 byte");
+        RETURN_FALSE;
+    }
+
+    connection->error = 
+        OCILobWrite(connection->pServiceContext,
+                                       connection->pError,
+                                       mylob,
+                                       (ub4 *) &loblen,
+                                       (ub4) offset,
+                                       (dvoid *) (*var)->value.str.val,
+                                       (ub4) loblen,
+                                       OCI_ONE_PIECE,
+                                       (dvoid *)0,
+                    (sb4 (*)(dvoid *, dvoid *, ub4 *, ub1 *)) 0,
+                                       (ub2) 0,
+                                       (ub1) SQLCS_IMPLICIT );
+
+    if (connection->error) {
+        oci_error(connection->pError, "OCILobWrite", connection->error);
+        oci_handle_error(connection, connection->error);
+        RETURN_FALSE;
+    }
+
+    RETURN_TRUE;
+}
+
+/* }}} */
+
+/* {{{ proto string ocicloselob(object lob)
+   Closes lob descriptor */
+
+PHP_FUNCTION(ocicloselob)
+{
+       zval *id;
+       int inx;
+       OCILobLocator *mylob;
+       oci_connection *connection;
+       oci_descriptor *descriptor;
+
+       if ((id = getThis()) != 0) {
+               inx = _oci_get_ocidesc(id,&descriptor);
+               if (inx) {
+
+            mylob = (OCILobLocator *) descriptor->ocidescr;
+
+            if (! mylob) {
+                RETURN_FALSE;
+            }
+
+            connection = descriptor->conn;
+
+            connection->error = OCILobClose (connection->pServiceContext, 
+                                             connection->pError, 
+                                             mylob);
+
+            if (connection->error) {
+                oci_error(connection->pError, "OCILobClose", connection->error);
+                oci_handle_error(connection, connection->error);
+                RETURN_FALSE;
+            }
+
+                       oci_debug("oci_close_lob: descr=%d",inx);
+                       RETURN_TRUE;
+               }
+       }
+
+       php_error(E_NOTICE, "OCICloselob() should not be called like this. Use $somelob->close() to close a LOB");
+
+       RETURN_FALSE;
+}
+
+/* }}} */
+
+#endif 
+
 /* {{{ proto string ocinewdescriptor(int connection [, int type])
    Initialize a new empty descriptor LOB/FILE (LOB is default) */
 
@@ -3991,6 +4144,7 @@ PHP_FUNCTION(ociresult)
 
 /* }}} */
 
+
 /* {{{ proto string ociserverversion(int conn)
    Return a string containing server version information */