mysql udf函数怎么调用

mysql udf函数怎么调用,第1张

1)基本用户定义函数是一类代码,对MYSQL服务器功能进行扩充,通过添加新函数,性质就象使用本地MYSQL函数abs()或concat().UDF是用C(或C++)写的。也许还可以用BASIC,.NET或其它什么虽然还没见过有人这么做。

2)从字面上何以知道UDF是很有用的,尤其当需要扩展MYSQL服务器功能时。下表给出了最佳解决方法的比较:

MethodSpeedLanguageDevelopment

方法 速度 语言开发

Stored Procedures slow SQL ~minutes (for small functions)

存储过程 慢 SQL ~分钟(对于小函数)

UDF fast C ~hour

UDF 快C ~小时

Native Function fast Cmajor pain in the ***

本地函数 快C 未知

慢的意思是和其它比较时。存储过程和一般SQL语句比仍然是很快的。

对本地函数的一点解释:本质上和UDF没太大区别。但是必须用MYSQL的资源代码来写然后重新编译全部。这将是很大的工作量,必须一边又一边的用最新版的MYSQL来完成这项工作。

3)这部分很简单。当完成了一个UDF,只是使用它就可以了。例如:"SELECT MyFunction(data1, data2) FROM table"

4)编写UDF

现在开发写一个UDF:

建立一个新的shared-library项目(该例中用的VC++ 6.0建立一个标准的DLL)

首先需要一些头文件。这些头文件是标准的头文件和MYSQL服务器的包含目录里的文件

#ifdef STANDARD

/* STANDARD is defined, don't use any mysql functions */

#include

#include

#include

#ifdef __WIN__

typedef unsigned __int64 ulonglong/* Microsofts 64 bit types */

typedef __int64 longlong

#else

typedef unsigned long long ulonglong

typedef long long longlong

#endif /*__WIN__*/

#else

#include

#include

#endif

#include

#include

static pthread_mutex_t LOCK_hostname

现在必须决定需要哪类函数。本质上有两种选择:

该函数是聚合函数吗?(后面将学习很多关于聚合函数的内容)

返回类型是什么?有4个选择:

类型 描述

STRING 一个合法的字符串,转换成char*类型

INTEGER 一个普通的整型变量,转换成64位的整型

REAL型 一个俘点数,转换成double型

DECIAML型 这个并没真正的结束,MYSQL将做字符串对待

现在开始讨论关于非聚合函数。必须声明并执行一些MYSQL使用UDF时用到的函数,但首先一些必要的结构必须并确:

UDF_INIT:

类型名称 描述

my_bool maybe_null 是1如果函数能返回NULL

unsigned intdecimals 针对REAL函数

unsigned long max_length 针对字符串函数

char * ptr 自由指针针对函数的数据

my_bool const_item 0如果结果是独立的

UDF_ARGS:

类型 名称 描述

unsigned int arg_count成员数量

enum Item_result * arg_type 成员类型的数组

char **args 指向成员的指针的数组

unsigned long *lengths 成员长度的数组(针对字符串)

char * maybe_null "maybe_null"标记的数组

char **attributes 指向成员属性的指针的数组

unsigned long *attribute_lengths属性长度数组

现在看一下该函数:

De-/Initialization:

Collapseextern "C" my_bool MyTest_init(UDF_INIT *initid, UDF_ARGS *args,

char *message)

{

//非常重要的一件事是建立内存

//需要

//需要一个很长的变量来保存检测数

//虽然该例中不需要

longlong* i = new longlong// 建立变量

*i = 0// 设初值

//指针变量中保存为一个字符指针

//确认不会遇到类型问题

initid->ptr = (char*)i

//检测成员的格式

if (args->arg_count != 1)

{

strcpy(message,"MyTest() requires one arguments")

return 1

}

if (args->arg_type[0] != INT_RESULT)

{

strcpy(message,"MyTest() requires an integer")

return 1

}

return 0

}

extern "C" void MyTest_deinit(UDF_INIT *initid)

{

//这里必须清空所分配的内存

//引入函数

delete (longlong*)initid->ptr

}

The actual function:

extern "C" longlong MyTest(UDF_INIT *initid, UDF_ARGS *args,

char *is_null, char *error)

{

/*最后这是实际的工作部分。该函数为每个记录调用,返回值或指向当前值的指针保存在UDF_ARGS变量中。必须获得值,完成计算并返回值。注意可以通过UDF_INIT变量进入MyTest_init中分配的内存,该例中将为每个值设置为5

*/

return *((longlong*)args->args[0])+5

}

全部完成!现在必须编译连接库,然后将其拷贝到 *** 作系统可以加载的目录下。通常在WINDOWS里是系统变量的定义路径。个人使用的是MYSQL服务器的bin目录。必须确认该目录是其它MYSQL不能访问的。然后确认所有MYSQL需要的函数功能。

必须告诉MYSQL,这必须直接了当:执行以下SQL指令:

CREATE [AGGREGATE] FUNCTION MyTest

RETURNS [INTEGER|STRING|REAL|DECIMAL] SONAME the_libraries_exact_name

现在可以想使用其他函数一样使用它了。

5)成员函数:

现在说一下成员函数。当的UDF是个成员函数,必须增加一些函数,一些函数在不同的方式中使用。调用次序是:

调用yTest_init来分配内存(就象一般的UDF一样)

MYSQL将表分类是通过GROUP BY

每组里的第一行调用MyTest_clear

每组里的第一列调用 MyTest_add

在组改变后或最后一列改变后调用MyTest得到结果

重复3到5直到所有列被处理。

调用MyTest_deinit清空内存

现在让看一下新的聚合函数所需的函数。该例中将简单的添加所有的值。(就象本地SUM函数)

void MyTest_clear(UDF_INIT *initid, char *is_null, char *error)

{

/*为每个新组重新将总数设置为0,当然必须分配一个longlong类型变量在在init函数中,并分配给指针

*/

*((longlong*)initid->ptr) = 0

}

void MyTest_add(UDF_INIT *initid, UDF_ARGS *args, char *is_null, char *error)

{

//为每列将当前值添加到总数

*((longlong*)initid->ptr) = *((longlong*)initid->ptr) +

*((longlong*)args->args[0])

}

longlong MyTest(UDF_INIT *initid, UDF_ARGS *args, char *is_null, char *error)

{

//最后返回总值

return *((longlong*)initid->ptr)

}

6)更进一步的问题:

在写一些复杂的UDF时需要注意几个问题:

一个字符串函数应该返回一个指向结果的指针并且设置*result和*length作为目录和返回值的长度值。例如:

memcpy(result, "result string", 13)

*length = 13

MyTest建立的结果缓冲区是255字节。如果的结果保存在里面。不必担心结果的内存分配问题。

如果的字符串函数需要返回一个大于255字节长度的字符串。必须用malloc或新的MyTest_init或MyTest函数分配,然后用MyTest_deinit释放它。能用UDF_INIT的指针保存分配的内存地址,并在MyTest中重用。

在主函数中指定一个错误返回,设置 *error为1:如果MyTest()为任何列将*error设置为1,则函数的值是NULL针对于当前列,以及对任何的通过MyTest()被调用的声明中并发的列请求。

想了解更多内容看一下MYSQL在线帮助。

7)一些指导方针:

如果确实希望的UDF运行良好,这里有一些建议:)

不要在UDF中调用任何其他的程序或进程

不要保存任何的本地信息。(这些在普通的库里已经共享)

不要分配任何的全局或静态的变量。

始终检测成员的类型。就象MYSQL将所有类型都转换为字符类型。如果将一个字符类型转换成整型指针可能会出错。

特别注意内存的分配。如果有内存泄漏问题会使服务器彻底崩溃!

8)调式UDF

调试UDF需要勇气因为如果UDF有问题,每次都会使整个MYSQL服务器死掉。所以写了一个命令行工具,来围绕这个问题工作。仅仅运行它,它会模仿"SELECT"调用指令将结果保存到库文件中,可以打印所有的结果行。所以当UDF存在一些错误只是该程序崩溃而不会是整个服务器。

langouster_udf.dll 专用网马(php) 一、功能:利用MYSQL的Create Function语句,将MYSQL账号转化为系统system权限。 二、适用场合:1.目标系统是Windows(Win2000,XP,Win2003);2.你已经拥有MYSQL的某个用户账号,此账号必须有对mysql的insert和delete权限以创建和抛弃函数(MYSQL文档原语)。 三、使用帮助: 第一步:将本文件上传到目标机上,填入你的MYSQL账号经行连接。 第二步:连接成功后,导出DLL文件,导出时请勿必注意导出路径(一般情况下对任何目录可写,无需考虑权限问题),对于MYSQL5.0以上版本,你必须将DLL导出到目标机器的系统目录(win 或 system32),否则在下一步 *** 作中你会看到"No paths allowed for shared library"错误。 第三步:使用SQL语句创建功能函数。语法:Create Function 函数名(函数名只能为下面列表中的其中之一) returns string soname '导出的DLL路径';对于MYSQL5.0以上版本,语句中的DLL不允许带全路径,如果你在第二步中已将DLL导出到系统目录,那么你就可以省略路径而使命令正常执行,否则你将会看到"Can't open shared library"错误,这时你必须将DLL重新导出到系统目录。 第四步:正确创建功能函数后,你就可以用SQL语句来使用这些功能了。语法:select 创建的函数名('参数列表'); 每个函数有不同的参数,你可以使用select 创建的函数名('help');来获得指定函数的参数列表信息。 第五步:使用完成后你可能需要删除在第二步中导出的DLL,但在删除DLL前请先删除你在第三步中创建的函数,否则删除 *** 作将失败,删除第三步中创建的函数的SQL语句为:drop function 创建的函数名; 四、功能函数说明: cmdshell 执行cmddownloader 下载者,到网上下载指定文件并保存到指定目录open3389 通用开3389终端服务,可指定端口(不改端口无需重启)backshell 反dShellProcessView 枚举系统进程KillProcess 终止指定进程regread 读注册表regwrite 写注册表shut 关机,注销,重启about 说明与帮助函数


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5906264.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-03-07
下一篇 2023-03-07

发表评论

登录后才能评论

评论列表(0条)

保存