new file: CMakeLists.txt

	new file:   outfile.c
	new file:   outfile.h

Author: Neo Chen

CMakeLists.txt

@@ -0,0 +1,6 @@
+cmake_minimum_required(VERSION 2.8)
+PROJECT(outfile)
+ADD_LIBRARY(outfile SHARED outfile.c)
+INCLUDE_DIRECTORIES(/usr/include/mysql)
+#TARGET_LINK_LIBRARIES(outfile )
+INSTALL(PROGRAMS liboutfile.so DESTINATION /usr/lib64/mysql/plugin/)

outfile.c

@@ -0,0 +1,169 @@
+/*
+Homepage: http://netkiller.github.io/
+Author: netkiller<netkiller@msn.com>
+*/
+#include <stdlib.h>
+#include <stdio.h>
+#include <mysql.h>
+#include <string.h>
+#include <sys/io.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <fcntl.h>
+
+#include "outfile.h"
+
+/* ------------------------ outfile_create ----------------------------- */
+
+my_bool outfile_create_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
+{
+
+  if (args->arg_count != 1)
+  {
+    strncpy(message,
+            "one arguments must be supplied: outfile_create('<pipename>').",
+            MYSQL_ERRMSG_SIZE);
+    return 1;
+  }
+  args->arg_type[0]= STRING_RESULT;
+
+  return 0;
+}
+
+char *outfile_create(UDF_INIT *initid, UDF_ARGS *args,
+                __attribute__ ((unused)) char *result,
+               unsigned long *length,
+                __attribute__ ((unused)) char *is_null,
+                __attribute__ ((unused)) char *error)
+{
+
+    char *status;
+	if (create_outfile(args->args[0]) == 0)
+        status = "ture";
+    else
+		status = "false";
+
+    *length = strlen(status);
+    return ((char *)status);
+
+}
+
+void outfile_create_deinit(UDF_INIT *initid)
+{
+  return;
+}
+
+/* ------------------------ outfile_remove ----------------------------- */
+
+my_bool outfile_remove_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
+{
+
+  if (args->arg_count != 1)
+  {
+    strncpy(message,"one arguments must be supplied: outfile_remove('<pipename>').", MYSQL_ERRMSG_SIZE);
+    return 1;
+  }
+
+  args->arg_type[0]= STRING_RESULT;
+
+  return 0;
+}
+
+char *outfile_remove(UDF_INIT *initid, UDF_ARGS *args,
+                __attribute__ ((unused)) char *result,
+               unsigned long *length,
+                __attribute__ ((unused)) char *is_null,
+                __attribute__ ((unused)) char *error)
+{
+
+    char *data;
+	if( remove_outfile(args->args[0]) == 0 )
+		data = "true";
+	else
+		//asprintf(&data, "ARG0=%s, ARG1=%d", args->args[0], errno);
+		data = "false";
+		
+    *length = strlen(data);
+    return ((char *)data);
+
+}
+
+void outfile_remove_deinit(UDF_INIT *initid)
+{
+  return;
+}
+
+/* ------------------------ outfile_read ----------------------------- */
+
+my_bool outfile_read_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
+{
+
+  if (args->arg_count != 1)
+  {
+    strncpy(message, "one arguments must be supplied: outfile_read('<pipename>').", MYSQL_ERRMSG_SIZE);
+    return 1;
+  }
+
+  args->arg_type[0]= STRING_RESULT;
+
+  return 0;
+}
+
+char *outfile_read(UDF_INIT *initid, UDF_ARGS *args,
+                __attribute__ ((unused)) char *result,
+               unsigned long *length,
+                __attribute__ ((unused)) char *is_null,
+                __attribute__ ((unused)) char *error)
+{
+
+    char *data;
+
+	data = read_outfile(args->args[0]);
+
+	//asprintf(&data, "ARG0=%s, ARG1=%d", args->args[0], args->args[1]);
+    *length = strlen(data);
+    return ((char *)data);
+
+}
+
+void outfile_read_deinit(UDF_INIT *initid)
+{
+  return;
+}
+
+/* ------------------------ outfile_write ----------------------------- */
+
+my_bool outfile_write_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
+{
+  if (args->arg_count != 2)
+  {
+    strncpy(message, "two arguments must be supplied: outfile_write('pipename','message').", MYSQL_ERRMSG_SIZE);
+    return 1;
+  }
+
+  args->arg_type[0]= STRING_RESULT;
+    return 0;
+}
+
+char *outfile_write(UDF_INIT *initid, UDF_ARGS *args,
+                __attribute__ ((unused)) char *result,
+               unsigned long *length,
+                __attribute__ ((unused)) char *is_null,
+                __attribute__ ((unused)) char *error)
+{
+
+	char *status;
+  //asprintf(&status, "SAFENET_URL=%s, SAFENET_KEY=%s", safe_url, safe_key);
+	if( write_outfile( args->args[0], args->args[1] ) == -1)
+		status = "false";
+	else
+		status = "true";
+  
+	*length = strlen(status);
+	return ((char *)status);
+}
+
+void outfile_write_deinit(UDF_INIT *initid)
+{
+   return;
+}

outfile.h

@@ -0,0 +1,57 @@
+my_bool outfile_remove_init(UDF_INIT *initid, UDF_ARGS *args, char *message);
+char *outfile_remove(UDF_INIT *initid, UDF_ARGS *args, char *result, unsigned long *length, char *is_null, char *error);
+void outfile_remove_deinit(UDF_INIT *initid);
+
+my_bool outfile_read_init(UDF_INIT *initid, UDF_ARGS *args, char *message);
+char *outfile_read(UDF_INIT *initid, UDF_ARGS *args, char *result, unsigned long *length, char *is_null, char *error);
+void outfile_read_deinit(UDF_INIT *initid);
+
+my_bool outfile_write_init(UDF_INIT *initid, UDF_ARGS *args, char *message);
+char *outfile_write(UDF_INIT *initid, UDF_ARGS *args, char *result, unsigned long *length, char *is_null, char *error);
+void outfile_write_deinit(UDF_INIT *initid);
+
+char* concat(const char* str1, const char* str2)
+{
+    char* res;
+    asprintf(&res, "%s%s", str1, str2);
+    return res;
+}
+
+char * read_outfile(char * path)  
+{  
+    int fd;
+    char buf[8];
+	char *result="";
+    /* open, read, and display the message from the FIFO */
+    fd = open(path, O_RDONLY);
+    while( read(fd, buf, sizeof(buf)) > 0){
+		result = concat(result,buf);
+		memset(buf, 0, sizeof(buf));
+	}
+    //printf("Received: %s\n", buf);
+    close(fd);
+	
+    return result; 
+}  
+
+int write_outfile(char * path, char * msg)  
+{  
+    	
+	FILE* file = fopen(path, "a+");
+	if (file == 0) {
+		return 0;
+	}
+    fputs(msg, file);
+    fclose(file);
+	return 1;
+}
+int create_outfile(char * path)
+{
+	/* create the FIFO (named pipe) */
+    return mkoutfile(path, 0660);
+}
+int remove_outfile(char *path)
+{
+	/* remove the FIFO */
+    return unlink(path);
+}