mysql怎么函数调用,MySQL函数调用

在mysql里怎样自定义函数,如何调用和执行

create function 函数名称(参数列表)

浮山ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景，ssl证书未来市场广阔！成为创新互联公司的ssl证书销售渠道，可以享受市场价格4-6折优惠！如果有意向欢迎电话联系或者加微信：13518219792（备注：SSL证书合作）期待与您的合作！

reurns 返回值类型

函数体

执行的方法很简单：

加载

** create function 函数名称 returns {string|real|integer}

** soname 你定义的动态库位置

释放！

** drop function 函数名称

mysql udf函数怎么调用

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

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

Method Speed Language Development

方法 速度 语言 开发

Stored Procedures slow SQL ~minutes (for small functions)

存储过程 慢 SQL ~分钟（对于小函数）

UDF fast C ~hour

UDF 快 C ~小时

Native Function fast C major 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 int decimals 针对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存在一些错误只是该程序崩溃而不会是整个服务器。

mysql 存储过程怎么调用？

php调用mysql存储过程和函数的方法

存储过程和函数是MySql5.0刚刚引入的。关于这方面的操作在PHP里面没有直接的支持。但是由于Mysql PHP API的设计，使得我们可以在以前的PHP版本中的mysql php api中支持存储过程和函数的调用。

在php中调用存储过程和函数。

1。调用存储过程的方法。

a。如果存储过程有 IN/INOUT参数，声明一个变量，输入参数给存储过程，该变量是一对，

一个php变量（也可以不必，只是没有php变量时，没有办法进行动态输入），一个Mysql

变量。

b。如果存储过程有OUT变量，声明一个Mysql变量。

mysql变量的声明比较特殊，必须让mysql服务器知道此变量的存在，其实也就是执行一条mysql语句。

入set @mysqlvar=$phpvar ;

c。使用mysql_query()/mysql_db_query()执行mysql 变量声明语句。

mysql_query("set @mysqlvar=$pbpvar");

这样，在mysql服务器里面就有一个变量，@mysqlar。如果是IN参数，那么其值可以由phpar传入。

d。 如果是存储过程。

1。执行 call procedure（）语句。

也就是mysql_query("call proceduer([var1]...)");

2. 如果有返回值，执行select @ar，返回执行结果。

mysql_query("select @var)"

接下来的操作就和php执行一般的mysql语句一样了。可以通过mydql_fetch_row()等函数获得结果。

如果时函数。 直接执行 select function（） 就可以了。

$host="localhost";

$user="root";

$password="11212";

$db="samp_db";

$dblink=mysql_connect($host,$user,$password)

or die("can't connect to mysql");

mysql_select_db($db,$dblink)

or die("can't select samp_db");

$res=mysql_query("set @a=$password",$dblink);

$res=mysql_query("call aa(@a)",$dblink);

$res=mysql_query("select @a",$dblink);

$row=mysql_fetch_row($res);

echo $row[0];

mysql存储过程怎么调用自定义函数

创建存储过程

mysql

delimiter

$

--

delimiter

$是设置

$为命令终止符号,代替默认的分号,因为分号有其他用处.

mysql

create

procedure

sp_test(IN

pi_id

int,

OUT

po_name

varchar(10))

-

begin

-

select

*

from

test.tb_test;

-

select

tb_test.name

into

po_name

from

test.tb_test

where

tb_test.id

=

pi_id;

-

end

-

$

Query

OK,

rows

affected

(0.00

sec)

mysql

delimiter

;

--

恢复分号作为分隔终止符号

5.调用存储过程

mysql

set

@po_name='';

Query

OK,

rows

affected

(0.00

sec)

mysql

call

sp_test(1,@po_name);

怎样用PHP中的MySQL操作函数

1. 建立MySQL 连接：mysql_connect

resource mysql_connect([string $server[, string $username [, string $password [, bool $new_link [, int $client flags]]]]])

打开或重复使用一个到MySQL服务器的连接。其中，server代表MySQL服务器，可以包括端口号，例如“hostname:port”。username和password分别代表登录MySQL服务器使用的用户名和密码。

2. 选择 MySQL 数据库：mysql_select_db

bool mysql_select_db(string $database_name[, resource $link_identifier])

设定与指定的连接标识符所关联的服务器上的当前数据库。如果没有指定连接标识符，则使用上一个打开的连接。如果没有打开的连接，本函数将无参数地调用mysql_connect()来尝试打开一个数据库连接。如果成功则返回true，失败则返回false。每个其后的mysgl_query()调用都会作用于活动数据库。

3. 执行查询：mysql_query

resource mysql_query(string $query[, resource $link_identifier])

向与指定的连接标识的关联的服务器中的当前活动数据库发送一条查询。如果没有指定 link_identifier，则使用上一个打开的连接。如果没有打开的连接，本函数会尝试无参数地调用mysql_connect()函数来建立一个连接，查询结果会被缓存。mysql_query()仅对SELECT、SHOW、EXPLAIN或DESCRIBE语句返回一个资源标识符，如果查询执行不正确则返回false。对于其他类型的SQL语句，mysgl_query()在执行成功时返回true，出错时返回false。非false的返回值意味着查询是合法的并能够被服务器执行但是并不说明任何影响到的或返回的行数。因为一条查询执行成功了但并未影响到或并未返回任何行的情况是可能发生的。

4. 从结果集中取得一行作为枚举数组：mysql_fetch_row

array mysql_fetch_row(resource $result)

从和指定的结果标识关联的结果集中取得一行数据并作为数组返回。每个结果的列储存在一个索引数组的单元中，偏移量从0开始。依次调用mysql_fetch_row()将返回结果集中的下一行，如果没有更多行则返回false。

5. 从结果集中取得一行作为关联数组，或数字数组，或二者兼有：mysql_fetch_array

array mysql_fetch_array(resource $result[, int $result_type])

mysql_fetch_row()的扩展版本。除了将数据以数字索引方式储存在数组中之外，还可以将数据作为关联索引储存，用字段名作为键名。如果结果中出现字段名重名的现象，最后一列将优先。要访问同名的其他列，必须用该列的数字索引或给该列起个别名。对有别名的列，用别名来访问其内容。

6. 关闭 MySQL 连接：mysql_close

bool mysql_close([resource $link_identifier])

mysql_close()关闭指定的连接标识所关联的到MySQL服务器的非持久连接。如果没有指定link_identifier，则关闭上一个打开的连接。

例PHP中使用MySQL数据库（mysql.php）

?php//连接MySQL数据库

mysql_connect('localhost', 'root', '123');

//选择当前数据库

//等效为执行USE test

mysql_select_db('test');

//在当前数据库执行SQL语句

$query = "SELECT * FROM students";

$result = mysql_query($query);

//操作上次查询返回的结果集，注意$result变量一般是需要的

while($student = mysql_fetch_array($result)) {

echo 'pre';

print_r($student);

echo '/pre';

}

?