Adding upstream version 13.4.upstream/13.4upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 163 insertions, 0 deletions

diff --git a/src/pl/plperl/SPI.xs b/src/pl/plperl/SPI.xs
new file mode 100644
index 0000000..b2db3bd
--- /dev/null
+++ b/src/pl/plperl/SPI.xs
@@ -0,0 +1,163 @@
+/**********************************************************************
+ * PostgreSQL::InServer::SPI
+ *
+ * SPI interface for plperl.
+ *
+ *    src/pl/plperl/SPI.xs
+ *
+ **********************************************************************/
+
+/* this must be first: */
+#include "postgres.h"
+
+/* perl stuff */
+#define PG_NEED_PERL_XSUB_H
+#include "plperl.h"
+#include "plperl_helpers.h"
+
+
+MODULE = PostgreSQL::InServer::SPI PREFIX = spi_
+
+PROTOTYPES: ENABLE
+VERSIONCHECK: DISABLE
+
+SV*
+spi_spi_exec_query(sv, ...)
+	SV* sv;
+	PREINIT:
+		HV *ret_hash;
+		int limit = 0;
+		char *query;
+	CODE:
+		if (items > 2)
+			croak("Usage: spi_exec_query(query, limit) "
+				  "or spi_exec_query(query)");
+		if (items == 2)
+			limit = SvIV(ST(1));
+		query = sv2cstr(sv);
+		ret_hash = plperl_spi_exec(query, limit);
+		pfree(query);
+		RETVAL = newRV_noinc((SV*) ret_hash);
+	OUTPUT:
+		RETVAL
+
+void
+spi_return_next(rv)
+	SV *rv;
+	CODE:
+		plperl_return_next(rv);
+
+SV *
+spi_spi_query(sv)
+	SV *sv;
+	CODE:
+		char* query = sv2cstr(sv);
+		RETVAL = plperl_spi_query(query);
+		pfree(query);
+	OUTPUT:
+		RETVAL
+
+SV *
+spi_spi_fetchrow(sv)
+	SV* sv;
+	CODE:
+		char* cursor = sv2cstr(sv);
+		RETVAL = plperl_spi_fetchrow(cursor);
+		pfree(cursor);
+	OUTPUT:
+		RETVAL
+
+SV*
+spi_spi_prepare(sv, ...)
+	SV* sv;
+	CODE:
+		int i;
+		SV** argv;
+		char* query = sv2cstr(sv);
+		if (items < 1)
+			Perl_croak(aTHX_ "Usage: spi_prepare(query, ...)");
+		argv = ( SV**) palloc(( items - 1) * sizeof(SV*));
+		for ( i = 1; i < items; i++)
+			argv[i - 1] = ST(i);
+		RETVAL = plperl_spi_prepare(query, items - 1, argv);
+		pfree( argv);
+		pfree(query);
+	OUTPUT:
+		RETVAL
+
+SV*
+spi_spi_exec_prepared(sv, ...)
+	SV* sv;
+	PREINIT:
+		HV *ret_hash;
+	CODE:
+		HV *attr = NULL;
+		int i, offset = 1, argc;
+		SV ** argv;
+		char *query = sv2cstr(sv);
+		if ( items < 1)
+			Perl_croak(aTHX_ "Usage: spi_exec_prepared(query, [\\%%attr,] "
+					   "[\\@bind_values])");
+		if ( items > 1 && SvROK( ST( 1)) && SvTYPE( SvRV( ST( 1))) == SVt_PVHV)
+		{
+			attr = ( HV*) SvRV(ST(1));
+			offset++;
+		}
+		argc = items - offset;
+		argv = ( SV**) palloc( argc * sizeof(SV*));
+		for ( i = 0; offset < items; offset++, i++)
+			argv[i] = ST(offset);
+		ret_hash = plperl_spi_exec_prepared(query, attr, argc, argv);
+		RETVAL = newRV_noinc((SV*)ret_hash);
+		pfree( argv);
+		pfree(query);
+	OUTPUT:
+		RETVAL
+
+SV*
+spi_spi_query_prepared(sv, ...)
+	SV * sv;
+	CODE:
+		int i;
+		SV ** argv;
+		char *query = sv2cstr(sv);
+		if ( items < 1)
+			Perl_croak(aTHX_ "Usage: spi_query_prepared(query, "
+					   "[\\@bind_values])");
+		argv = ( SV**) palloc(( items - 1) * sizeof(SV*));
+		for ( i = 1; i < items; i++)
+			argv[i - 1] = ST(i);
+		RETVAL = plperl_spi_query_prepared(query, items - 1, argv);
+		pfree( argv);
+		pfree(query);
+	OUTPUT:
+		RETVAL
+
+void
+spi_spi_freeplan(sv)
+	SV *sv;
+	CODE:
+		char *query = sv2cstr(sv);
+		plperl_spi_freeplan(query);
+		pfree(query);
+
+void
+spi_spi_cursor_close(sv)
+	SV *sv;
+	CODE:
+		char *cursor = sv2cstr(sv);
+		plperl_spi_cursor_close(cursor);
+		pfree(cursor);
+
+void
+spi_spi_commit()
+	CODE:
+		plperl_spi_commit();
+
+void
+spi_spi_rollback()
+	CODE:
+		plperl_spi_rollback();
+
+BOOT:
+    items = 0;  /* avoid 'unused variable' warning */