From 97480eafbc67ec7e84497868a1777ce0d7881e6c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Luis=20Fernando=20Mu=C3=B1oz=20Mej=C3=ADas?=
 <Luis.Fernando.Munoz.Mejias@cern.ch>
Date: Wed, 25 Mar 2009 18:16:24 +0100
Subject: Start the output module for Oracle.

Currently, resources are allocated, freed and the code compiles. No
tests yet.
---
 plugins/omoracle/omoracle.c | 139 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 139 insertions(+)
 create mode 100644 plugins/omoracle/omoracle.c

(limited to 'plugins/omoracle/omoracle.c')

diff --git a/plugins/omoracle/omoracle.c b/plugins/omoracle/omoracle.c
new file mode 100644
index 00000000..696cd908
--- /dev/null
+++ b/plugins/omoracle/omoracle.c
@@ -0,0 +1,139 @@
+/** omoracle.c
+
+    This is an output module feeding directly to an Oracle
+    database. It uses Oracle Call Interface, a propietary module
+    provided by Oracle.
+
+    Author: Luis Fernando Muñoz Mejías
+    <Luis.Fernando.Munoz.Mejias@cern.ch>
+
+    This file is part of rsyslog.
+*/
+#include "config.h"
+#include "rsyslog.h"
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <oci.h>
+#include <errno.h>
+#include <stdarg.h>
+#include <signal.h>
+#include <time.h>
+#include <assert.h>
+#include "dirty.h"
+#include "syslogd-types.h"
+#include "srUtils.h"
+#include "template.h"
+#include "module-template.h"
+#include "errmsg.h"
+#include "cfsysline.h"
+#include "omoracle.h"
+
+MODULE_TYPE_OUTPUT
+
+/**  */
+DEF_OMOD_STATIC_DATA
+DEFobjCurrIf(errmsg)
+
+typedef struct _instanceData {
+	OCIEnv* environment;
+	OCISession* session;
+	OCIError* error;
+	OCIServer* server;
+	OCIStmt* statement;
+	OCISvcCtx* service;
+	OCIAuthInfo* authinfo;
+	OCIBind* binding;
+} instanceData;
+
+/** Generic function for handling errors from OCI.
+
+    It will be called only inside CHECKERR and CHECKENV macros.
+
+    Arguments: handle The error or environment handle to check.
+    htype: OCI_HTYPE_* constant, usually OCI_HTYPE_ERROR or
+    OCI_HTYPE_ENV
+    status: status code to check, usually the return value of an OCI
+    function.
+
+    Returns OCI_SUCCESS on success, OCI_ERROR otherwise.
+*/
+static int oci_errors(void* handle, ub4 htype, sword status)
+{
+	sb4 errcode;
+	char buf[MAX_BUFSIZE];
+	
+	switch (status) {
+	case OCI_SUCCESS:
+		return OCI_SUCCESS;
+		break;
+	case OCI_SUCCESS_WITH_INFO:
+		printf ("OCI SUCCESS - With info\n");
+		break;
+	case OCI_NEED_DATA:
+		printf ("OCI NEEDS MORE DATA\n");
+		break;
+	case OCI_ERROR:
+		printf ("OCI GENERAL ERROR\n");
+		if (handle) {
+			OCIErrorGet(handle, 1, NULL, &errcode, buf, sizeof buf, htype);
+			printf ("Error message: %s", buf);
+		} else
+			printf ("NULL handle\n"
+				"Unable to extract further information");
+		break;
+	case OCI_INVALID_HANDLE:
+		printf ("OCI INVALID HANDLE\n");
+		break;
+	case OCI_STILL_EXECUTING:
+		printf ("Still executing...\n");
+		break;
+	case OCI_CONTINUE:
+		printf ("OCI CONTINUE\n");
+		break;
+	}
+	return OCI_ERROR;
+}
+
+
+/* Resource allocation */
+BEGINcreateInstance
+CODESTARTcreateInstance
+CHECKENV(pData->environment,
+	 OCIEnvCreate(&(pData->environment), OCI_DEFAULT,
+		      NULL, NULL, NULL, NULL, 0, NULL));
+CHECKENV(pData->environment,
+	 OCIHandleAlloc(pData->environment, &(pData->error),
+			OCI_HTYPE_ERROR, 0, NULL));
+CHECKENV(pData->environment,
+	 OCIHandleAlloc(pData->environment, &(pData->server),
+			OCI_HTYPE_SERVER, 0, NULL));
+CHECKENV(pData->environment,
+	 OCIHandleAlloc(pData->environment, &(pData->service),
+			OCI_HTYPE_SVCCTX, 0, NULL));
+CHECKENV(pData->environment,
+	 OCIHandleAlloc(pData->environment, &(pData->authinfo),
+			OCI_HTYPE_AUTHINFO, 0, NULL));
+finalize_it:
+ENDcreateInstance
+
+/** Free any resources allocated by createInstance. */
+BEGINfreeInstance
+CODESTARTfreeInstance
+
+OCIHandleFree(pData->environment, OCI_HTYPE_ENV);
+OCIHandleFree(pData->error, OCI_HTYPE_ERROR);
+OCIHandleFree(pData->server, OCI_HTYPE_SERVER);
+OCIHandleFree(pData->service, OCI_HTYPE_SVCCTX);
+OCIHandleFree(pData->authinfo, OCI_HTYPE_AUTHINFO);
+
+RETiRet;
+
+ENDfreeInstance
+
+/* BEGINmodInit() */
+/* CODESTARTmodInit */
+/* 	*ipIFVersProvided = CURR_MOD_IF_VERSION; */
+/* CODEmodInit_QueryRegCFSLineHdlr */
+/* 	CHKiRet(objUse(errmsg, CORE_COMPONENT)); */
+/* ENDmodInit */
-- 
cgit v1.2.3