mysqludf接口編程示例

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

2、ar *message);/args是 sql 語句傳回的參數(shù)，message是返回出錯信息使用這些都是規(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 型。這個函數(shù)目的是給用戶提供一個方式，檢驗由mysql 參數(shù)傳進來的數(shù)據(jù)是否正確，如果正確則對其進行主函數(shù)執(zhí)行，否則程序結(jié)束。另外 mysqludf 中暫時不支

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

4、) malloc(100) ) ) strcpy(message,couldnt allocate memory 100); return1; */ return0; /*我的代碼最終沒有采用事先分配內(nèi)存的方式，而是準備在主函數(shù)中申請空間。這里需要注意，成功一定要返回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)上收集，若侵犯了您的利益，請聯(lián)系(qq ：253169161)，我將立即核對刪除。/exit(); if(numbytes = send(sockfd,senddata,strlen(senddata),0)

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

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