1)基本用戶定義函數(shù)是一類代碼,對MYSQL服務(wù)器功能進行擴充,通過添加新函數(shù),性質(zhì)就象使用本地MYSQL函數(shù)abs()或concat().UDF是用C(或C++)寫的。也許還可以用BASIC,.NET或其它什么雖然還沒見過有人這么做。
創(chuàng)新互聯(lián)建站堅持“要么做到,要么別承諾”的工作理念,服務(wù)領(lǐng)域包括:成都做網(wǎng)站、網(wǎng)站設(shè)計、企業(yè)官網(wǎng)、英文網(wǎng)站、手機端網(wǎng)站、網(wǎng)站推廣等服務(wù),滿足客戶于互聯(lián)網(wǎng)時代的德安網(wǎng)站設(shè)計、移動媒體設(shè)計的需求,幫助企業(yè)找到有效的互聯(lián)網(wǎng)解決方案。努力成為您成熟可靠的網(wǎng)絡(luò)建設(shè)合作伙伴!
2)從字面上何以知道UDF是很有用的,尤其當(dāng)需要擴展MYSQL服務(wù)器功能時。下表給出了最佳解決方法的比較:
Method Speed Language Development
方法 速度 語言 開發(fā)
Stored Procedures slow SQL ~minutes (for small functions)
存儲過程 慢 SQL ~分鐘(對于小函數(shù))
UDF fast C ~hour
UDF 快 C ~小時
Native Function fast C major pain in the ***
本地函數(shù) 快 C 未知
慢的意思是和其它比較時。存儲過程和一般SQL語句比仍然是很快的。
對本地函數(shù)的一點解釋:本質(zhì)上和UDF沒太大區(qū)別。但是必須用MYSQL的資源代碼來寫然后重新編譯全部。這將是很大的工作量,必須一邊又一邊的用最新版的MYSQL來完成這項工作。
3)這部分很簡單。當(dāng)完成了一個UDF,只是使用它就可以了。例如:"SELECT MyFunction(data1, data2) FROM table"
4)編寫UDF
現(xiàn)在開發(fā)寫一個UDF:
建立一個新的shared-library項目(該例中用的VC++ 6.0建立一個標(biāo)準(zhǔn)的DLL)
首先需要一些頭文件。這些頭文件是標(biāo)準(zhǔn)的頭文件和MYSQL服務(wù)器的包含目錄里的文件
#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;
現(xiàn)在必須決定需要哪類函數(shù)。本質(zhì)上有兩種選擇:
該函數(shù)是聚合函數(shù)嗎?(后面將學(xué)習(xí)很多關(guān)于聚合函數(shù)的內(nèi)容)
返回類型是什么?有4個選擇:
類型 描述
STRING 一個合法的字符串,轉(zhuǎn)換成char*類型
INTEGER 一個普通的整型變量,轉(zhuǎn)換成64位的整型
REAL型 一個俘點數(shù),轉(zhuǎn)換成double型
DECIAML型 這個并沒真正的結(jié)束,MYSQL將做字符串對待
現(xiàn)在開始討論關(guān)于非聚合函數(shù)。必須聲明并執(zhí)行一些MYSQL使用UDF時用到的函數(shù),但首先一些必要的結(jié)構(gòu)必須并確:
UDF_INIT:
類型 名稱 描述
my_bool maybe_null 是1如果函數(shù)能返回NULL
unsigned int decimals 針對REAL函數(shù)
unsigned long max_length 針對字符串函數(shù)
char * ptr 自由指針針對函數(shù)的數(shù)據(jù)
my_bool const_item 0如果結(jié)果是獨立的
UDF_ARGS:
類型 名稱 描述
unsigned int arg_count 成員數(shù)量
enum Item_result * arg_type 成員類型的數(shù)組
char ** args 指向成員的指針的數(shù)組
unsigned long * lengths 成員長度的數(shù)組(針對字符串)
char * maybe_null "maybe_null"標(biāo)記的數(shù)組
char ** attributes 指向成員屬性的指針的數(shù)組
unsigned long * attribute_lengths 屬性長度數(shù)組
現(xiàn)在看一下該函數(shù):
De-/Initialization:
Collapseextern "C" my_bool MyTest_init(UDF_INIT *initid, UDF_ARGS *args,
char *message)
{
//非常重要的一件事是建立內(nèi)存
//需要
//需要一個很長的變量來保存檢測數(shù)
//雖然該例中不需要
longlong* i = new longlong; // 建立變量
*i = 0; // 設(shè)初值
//指針變量中保存為一個字符指針
//確認(rèn)不會遇到類型問題
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)
{
//這里必須清空所分配的內(nèi)存
//引入函數(shù)
delete (longlong*)initid-ptr;
}
The actual function:
extern "C" longlong MyTest(UDF_INIT *initid, UDF_ARGS *args,
char *is_null, char *error)
{
/*最后這是實際的工作部分。該函數(shù)為每個記錄調(diào)用,返回值或指向當(dāng)前值的指針保存在UDF_ARGS變量中。必須獲得值,完成計算并返回值。注意可以通過UDF_INIT變量進入MyTest_init中分配的內(nèi)存,該例中將為每個值設(shè)置為5
*/
return *((longlong*)args-args[0])+5;
}
全部完成!現(xiàn)在必須編譯連接庫,然后將其拷貝到操作系統(tǒng)可以加載的目錄下。通常在WINDOWS里是系統(tǒng)變量的定義路徑。個人使用的是MYSQL服務(wù)器的bin目錄。必須確認(rèn)該目錄是其它MYSQL不能訪問的。然后確認(rèn)所有MYSQL需要的函數(shù)功能。
必須告訴MYSQL,這必須直接了當(dāng):執(zhí)行以下SQL指令:
CREATE [AGGREGATE] FUNCTION MyTest
RETURNS [INTEGER|STRING|REAL|DECIMAL] SONAME the_libraries_exact_name
現(xiàn)在可以想使用其他函數(shù)一樣使用它了。
5)成員函數(shù):
現(xiàn)在說一下成員函數(shù)。當(dāng)?shù)腢DF是個成員函數(shù),必須增加一些函數(shù),一些函數(shù)在不同的方式中使用。調(diào)用次序是:
調(diào)用yTest_init來分配內(nèi)存(就象一般的UDF一樣)
MYSQL將表分類是通過GROUP BY
每組里的第一行調(diào)用MyTest_clear
每組里的第一列調(diào)用 MyTest_add
在組改變后或最后一列改變后調(diào)用MyTest得到結(jié)果
重復(fù)3到5直到所有列被處理。
調(diào)用MyTest_deinit清空內(nèi)存
現(xiàn)在讓看一下新的聚合函數(shù)所需的函數(shù)。該例中將簡單的添加所有的值。(就象本地SUM函數(shù))
void MyTest_clear(UDF_INIT *initid, char *is_null, char *error)
{
/*為每個新組重新將總數(shù)設(shè)置為0,當(dāng)然必須分配一個longlong類型變量在在init函數(shù)中,并分配給指針
*/
*((longlong*)initid-ptr) = 0;
}
void MyTest_add(UDF_INIT *initid, UDF_ARGS *args, char *is_null, char *error)
{
//為每列將當(dāng)前值添加到總數(shù)
*((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)更進一步的問題:
在寫一些復(fù)雜的UDF時需要注意幾個問題:
一個字符串函數(shù)應(yīng)該返回一個指向結(jié)果的指針并且設(shè)置*result和*length作為目錄和返回值的長度值。例如:
memcpy(result, "result string", 13);
*length = 13;
MyTest建立的結(jié)果緩沖區(qū)是255字節(jié)。如果的結(jié)果保存在里面。不必?fù)?dān)心結(jié)果的內(nèi)存分配問題。
如果的字符串函數(shù)需要返回一個大于255字節(jié)長度的字符串。必須用malloc或新的MyTest_init或MyTest函數(shù)分配,然后用MyTest_deinit釋放它。能用UDF_INIT的指針保存分配的內(nèi)存地址,并在MyTest中重用。
在主函數(shù)中指定一個錯誤返回,設(shè)置 *error為1:如果MyTest()為任何列將*error設(shè)置為1,則函數(shù)的值是NULL針對于當(dāng)前列,以及對任何的通過MyTest()被調(diào)用的聲明中并發(fā)的列請求。
想了解更多內(nèi)容看一下MYSQL在線幫助。
7)一些指導(dǎo)方針:
如果確實希望的UDF運行良好,這里有一些建議:)
不要在UDF中調(diào)用任何其他的程序或進程
不要保存任何的本地信息。(這些在普通的庫里已經(jīng)共享)
不要分配任何的全局或靜態(tài)的變量。
始終檢測成員的類型。就象MYSQL將所有類型都轉(zhuǎn)換為字符類型。如果將一個字符類型轉(zhuǎn)換成整型指針可能會出錯。
特別注意內(nèi)存的分配。如果有內(nèi)存泄漏問題會使服務(wù)器徹底崩潰!
8)調(diào)式UDF
調(diào)試UDF需要勇氣因為如果UDF有問題,每次都會使整個MYSQL服務(wù)器死掉。所以寫了一個命令行工具,來圍繞這個問題工作。僅僅運行它,它會模仿"SELECT"調(diào)用指令將結(jié)果保存到庫文件中,可以打印所有的結(jié)果行。所以當(dāng)UDF存在一些錯誤只是該程序崩潰而不會是整個服務(wù)器。
最起碼包含mysql.h
實例代碼:
#include stdlib.h
#include stdio.h
#include "mysql.h"
int main(int argc, char *argv[]) {
MYSQL *conn_ptr;
conn_ptr = mysql_init(NULL);
if (!conn_ptr) {
fprintf(stderr, "mysql_init failed\n");
return EXIT_FAILURE;
}
conn_ptr = mysql_real_connect(conn_ptr, "localhost", "rick", "secret",
"foo", 0, NULL, 0);//連接數(shù)據(jù)庫
if (conn_ptr) {
printf("Connection success\n");
} else {
printf("Connection failed\n");
}
mysql_close(conn_ptr);
return EXIT_SUCCESS;
}
編譯:(假定上面文件取名 con.c,在當(dāng)前目錄下)
gcc -I/usr/include/mysql con.c -L/usr/lib/mysql -lmysqlclient -o con
方法如下:
1.頭文件:
#include
#include
#include//這個是必需要包含的,下面對mysql的所有操作函數(shù),都出自這里
2.定義一個MYSQL變量:
MYSQLmysql;
這里MYSQL是一個用于連接MySql數(shù)據(jù)庫的變量。
在后面對mysql數(shù)據(jù)庫的操作中,我們就用這個MYSQL變量作為句柄的。
3.定義數(shù)據(jù)庫參數(shù):
charhost[32]=”localhost”;
charuser[32]=”username”;
charpasswd[32]=”pwd”;
chardbname[32]=”testdb”;
4.數(shù)據(jù)庫操作
1).初始化數(shù)據(jù)庫:
mysql_init(mysql);
2).連接數(shù)據(jù)庫:
mysql_real_connect(mysql,host,user,passwd,dbname,0,NULL,0);
我們在操作時,可以對以上的函數(shù)進行if測試,如果初始化或者連接出錯,作出相應(yīng)提示,以便調(diào)試。
5.對數(shù)據(jù)庫的操作:
Mysql_query(mysql,“select*fromtestdbwherecondition”);
我們在實際操作中,為了更方便的使用程序中的某些變量,我們將會用到一個函數(shù):
intsprintf(char*str,constchar*format,?);
這個函數(shù)用來格式化我們的字符串,然后將變量按照給你的格式,賦給第一個參數(shù)。
我們使用這個方法方法可以很方便的使用我們的變量來對數(shù)據(jù)庫進行操作。例如我們將要進行數(shù)據(jù)庫的查詢操作,我們就可以這樣使用:
sprintf(sql,”select*fromtestdbwhereusername=‘%s’”,u_name);
然后使用mysql_query(mysql,sql)進行查詢。
MySQL是一個關(guān)系型數(shù)據(jù)庫管理系統(tǒng),由瑞典MySQLAB公司開發(fā),屬于Oracle旗下產(chǎn)品。MySQL是最流行的關(guān)系型數(shù)據(jù)庫管理系統(tǒng)之一,在WEB應(yīng)用方面,MySQL是最好的RDBMS(RelationalDatabaseManagementSystem,關(guān)系數(shù)據(jù)庫管理系統(tǒng))應(yīng)用軟件之一。
鏈表是一種物理存儲單元上非連續(xù)、非順序的存儲結(jié)構(gòu),數(shù)據(jù)元素的邏輯順序是通過鏈表中的指針鏈接次序?qū)崿F(xiàn)的。鏈表由一系列結(jié)點(鏈表中每一個元素稱為結(jié)點)組成,結(jié)點可以在運行時動態(tài)生成。每個結(jié)點包括兩個部分:一個是存儲數(shù)據(jù)元素的數(shù)據(jù)域,另一個是存儲下一個結(jié)點地址的指針域。相比于線性表順序結(jié)構(gòu),操作復(fù)雜。由于不必須按順序存儲,鏈表在插入的時候可以達到O(1)的復(fù)雜度,比另一種線性表順序表快得多,但是查找一個節(jié)點或者訪問特定編號的節(jié)點則需要O(n)的時間,而線性表和順序表相應(yīng)的時間復(fù)雜度分別是O(logn)和O(1)。
2、如不是安裝在默認(rèn)目錄,則編譯器可能無法找到正確的文件路徑,則可在編譯器中設(shè)置mysql的include、lib路徑(在mysql的安裝目錄下的include目錄);
3、記得加入winsock.h和mysql.h,winsock.h最好在mysql.h前面,否則VC可能報錯;
4、記得在設(shè)置里加入libmysql.lib wsock32.lib,然后還記得設(shè)置include 和lib文件夾,就可以了;