mysql用 fifo 记录日志_fifo.c · Neo Chan/mysql-fifo-plugin - Gitee.com
/*
Homepage: http://netkiller.github.io/
Author: netkiller
*/
#include
#include
#include
#include
#include
#include
#include
#include
#include "fifo.h"
/* ------------------------ fifo_create ----------------------------- */
my_bool fifo_create_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{
if (args->arg_count != 1)
{
strncpy(message,
"one arguments must be supplied: fifo_create('').",
MYSQL_ERRMSG_SIZE);
return 1;
}
args->arg_type[0]= STRING_RESULT;
return 0;
}
char *fifo_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_fifo(args->args[0]) == 0)
status = "ture";
else
status = "false";
*length = strlen(status);
return ((char *)status);
}
void fifo_create_deinit(UDF_INIT *initid)
{
return;
}
/* ------------------------ fifo_remove ----------------------------- */
my_bool fifo_remove_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{
if (args->arg_count != 1)
{
strncpy(message,"one arguments must be supplied: fifo_remove('').", MYSQL_ERRMSG_SIZE);
return 1;
}
args->arg_type[0]= STRING_RESULT;
return 0;
}
char *fifo_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_fifo(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 fifo_remove_deinit(UDF_INIT *initid)
{
return;
}
/* ------------------------ fifo_read ----------------------------- */
my_bool fifo_read_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{
if (args->arg_count != 1)
{
strncpy(message, "one arguments must be supplied: fifo_read('').", MYSQL_ERRMSG_SIZE);
return 1;
}
args->arg_type[0]= STRING_RESULT;
return 0;
}
char *fifo_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_fifo(args->args[0]);
//asprintf(&data, "ARG0=%s, ARG1=%d", args->args[0], args->args[1]);
*length = strlen(data);
return ((char *)data);
}
void fifo_read_deinit(UDF_INIT *initid)
{
return;
}
/* ------------------------ fifo_write ----------------------------- */
my_bool fifo_write_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
{
if (args->arg_count != 2)
{
strncpy(message, "two arguments must be supplied: fifo_write('pipename','message').", MYSQL_ERRMSG_SIZE);
return 1;
}
args->arg_type[0]= STRING_RESULT;
return 0;
}
char *fifo_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_fifo( args->args[0], args->args[1] ) == -1)
status = "false";
else
status = "true";
*length = strlen(status);
return ((char *)status);
}
void fifo_write_deinit(UDF_INIT *initid)
{
return;
}
一键复制
编辑
Web IDE
原始数据
按行查看
历史