mysqludf接口編程示例

1、本文檔為網(wǎng)上收集，若侵犯了您的利益，請(qǐng)聯(lián)系(qq ：253169161)，我將立即核對(duì)刪除。mysql udf 接口編程示例/*首先參考mysql 官方提供的udf_example.c 文件，將需要include 的代碼復(fù)制過(guò)來(lái)，然后就可以根據(jù)需要編寫(xiě)自己的函數(shù)了。我這里給出的示例是一個(gè)向指定ip 和端口， post 數(shù)據(jù)的例子，然后用網(wǎng)絡(luò)調(diào)試助手進(jìn)行測(cè)試。首先根據(jù)示例中的指示，需要建立3 個(gè)函數(shù)分別是初始化函數(shù)，執(zhí)行函數(shù)，還有反初始化函數(shù)。首先對(duì)這三個(gè)函數(shù)進(jìn)行聲明。如下：*/ my_boolhttp_post_init(udf_init *initid, udf_args *args, ch

2、ar *message);/args是 sql 語(yǔ)句傳回的參數(shù)，message是返回出錯(cuò)信息使用這些都是規(guī)定好的。longlonghttp_post(udf_init *initid, udf_args *args, char *is_null,char *error);/主函數(shù)體voidhttp_post_deinit(udf_init *initid);/反初始化函數(shù)體/*其中 http_post_init 需要返回my_bool 型。這個(gè)函數(shù)目的是給用戶提供一個(gè)方式，檢驗(yàn)由mysql 參數(shù)傳進(jìn)來(lái)的數(shù)據(jù)是否正確，如果正確則對(duì)其進(jìn)行主函數(shù)執(zhí)行，否則程序結(jié)束。另外 mysqludf 中暫時(shí)不支

3、持在主函數(shù)體內(nèi)申請(qǐng)內(nèi)存，所以如果有要申請(qǐng)內(nèi)存的操作，需要放在初始化過(guò)程中。但請(qǐng)注意，在udf 中好像對(duì)于申請(qǐng)和釋放內(nèi)存不是線程安全的，我的程序在多線程運(yùn)行狀態(tài)下，會(huì)發(fā)生 free 出錯(cuò)的情況，應(yīng)該是多次free 出錯(cuò)，但我在程序中只free 了一次。所以建議大家不要使用，如果需要空間較大，就建立一個(gè)大一點(diǎn)的靜態(tài)空間吧(數(shù)組 )。另外申請(qǐng)空間時(shí)需要使用mysqludf 提供的變量名，initid-ptr ，代碼示例如下，然后在主程序中直接使用initid-ptr ，最后在http_post_deinit中進(jìn)行釋放。具體看udf_example.c*/ if(!(initid-ptr=(char*

4、) malloc(100) ) ) strcpy(message,couldnt allocate memory 100); return1; */ return0; /*我的代碼最終沒(méi)有采用事先分配內(nèi)存的方式，而是準(zhǔn)備在主函數(shù)中申請(qǐng)空間。這里需要注意，成功一定要返回0，這也是udf 接口規(guī)定的，如果mysql 發(fā)現(xiàn)返回值是1，程序立刻結(jié)束。*/ my_boolhttp_post_init(udf_init *initid, udf_args *args, char *message) if(args-arg_count args1); serv_addr.sin_addr.s_addr=in

5、et_addr(args-args0); bzero(&(serv_addr.sin_zero),8); charsenddata128000=0; if(args-arg_count = 4 & (args-args3!=null) ) intargsnum=strlen(args-args3); sprintf(senddata,post /?%s http/1.1rncontent-length:%drnrn%s,args-args2,argsnum,args-args3); else sprintf(senddata,post /?%s http/1.1rn,args-

6、args2); if(sockfd = socket(af_inet,sock_stream,0) = -1) close(sockfd); return 1; /exit(); if(connect(sockfd,(struct sockaddr *)&serv_addr,sizeof(serv_addr) = -1) close(sockfd); return1; 本文檔為網(wǎng)上收集，若侵犯了您的利益，請(qǐng)聯(lián)系(qq ：253169161)，我將立即核對(duì)刪除。/exit(); if(numbytes = send(sockfd,senddata,strlen(senddata),0)

7、= -1) close(sockfd); return1; / exit(); close(sockfd); return0; /由于我沒(méi)有申請(qǐng)空間(melloc) ，所以我的反初始化函數(shù)為空voidhttp_post_deinit(udf_init *initid) /將程序保存為http_post.c 編譯如下 (請(qǐng)根據(jù)機(jī)器上的mysql 路徑進(jìn)行調(diào)整 )：gcc-wall-i/usr/local/webserver/mysql/include/mysql/-sharedhttp_post.c-ohttp_post.so-fpic/使用mysql 提供的頭文件生成動(dòng)態(tài)鏈接庫(kù)cp-fhttp

8、_post.so/usr/local/webserver/mysql/lib/mysql/plugin/http_post.so/將生成的.so 文件放入 mysql 的 plugin 文件夾下/進(jìn)入 mysql 對(duì)動(dòng)態(tài)鏈接庫(kù)中的函數(shù)進(jìn)行安裝cd/usr/local/webserver/mysql/bin/mysql ./mysql /在 mysql 命令行下輸入如下命令：mysqldropfunctionifexistshttp_post; /其目的是如果系統(tǒng)內(nèi)安裝了同名函數(shù)先進(jìn)性drop。mysqlcreatefunctionhttp_postreturnsintegersonamehttp_post.so; /生成 http_post 函數(shù)，并指明調(diào)用來(lái)源是http_post.so。/最后調(diào)用函數(shù)，其目的是向指定ip 和端口發(fā)送post 數(shù)據(jù)。調(diào)用前先打開(kāi)指定ip 主機(jī)上的網(wǎng)絡(luò)調(diào)試助手，并監(jiān)聽(tīng)3888 端口。mysq