一、前期準(zhǔn)備
開(kāi)發(fā)MYSQL擴(kuò)展,當(dāng)然得先安裝MYSQL
下載mysql-essential-5.1.65-win32
必須選上紅色的選項(xiàng),因?yàn)殚_(kāi)發(fā)MYSQL擴(kuò)展時(shí),需要頭文件和mysql的動(dòng)態(tài)庫(kù)。否則擴(kuò)展無(wú)法編譯成功。
這個(gè)擴(kuò)展的目的主要是熟悉ZEND API,并且理解如何提供PHP API。
實(shí)現(xiàn)的PHP API有:
PHP_FUNCTION(my_mysql_connect);
PHP_FUNCTION(my_mysql_close);
PHP_FUNCTION(my_mysql_get_conn);//通過(guò)鏈接池獲取mysql資源,這個(gè)連接池只是簡(jiǎn)單的自動(dòng)擴(kuò)容,并沒(méi)有收縮。
PHP_FUNCTION(my_mysql_select_db);//切換數(shù)據(jù)庫(kù)
PHP_FUNCTION(my_mysql_ping);
PHP_FUNCTION(my_mysql_query);//執(zhí)行sql,可以是SELECT或INSERT、UPDATE、DELETE等有返回值與無(wú)返回值的查詢語(yǔ)句
PHP_FUNCTION(my_mysql_fetch_assoc);//獲取返回結(jié)果集
PHP_FUNCTION(my_mysql_get_insert_id);//獲取上一次執(zhí)行INSERT的自增ID
二、開(kāi)發(fā)思路
1.通過(guò)ext_skel_win32.php(骨架工具)創(chuàng)建my_mysql擴(kuò)展。
2.使用VS2008打開(kāi)my_myqsl.dsp,編輯項(xiàng)目屬性。
2.1 切換為Release版本,默認(rèn)是DEBUG版本
2.2 右鍵項(xiàng)目屬性-》通配屬性-》C/C++-》預(yù)處理器-》預(yù)處理器定義除去其中的ZTS=1,因?yàn)槲覀儗⒕幾g為NTS版本。(非線程安全)
2.3 右鍵項(xiàng)目屬性-》通配屬性-》C/C++-》常規(guī)-》附加包含目錄,新增MYSQL_ROOT/include。引入頭文件搜索路徑。
這樣當(dāng)使用#include "mysql.h"時(shí),就不會(huì)出現(xiàn)搜索不到頭文件的錯(cuò)誤
2.4 右鍵項(xiàng)目屬性-》通配屬性-》鏈接器-》常規(guī)-》附加庫(kù)目錄,新增MYSQL_ROOT/lib/opt,編譯擴(kuò)展時(shí)需要鏈接的DLL都在其中。(另外不要忘記引入php5nts.lib的路徑,這是任一擴(kuò)展編譯時(shí)都需要引入的)
2.5 右鍵項(xiàng)目屬性-》通配屬性-》鏈接器-》輸入-》附加依賴項(xiàng)新增libmySQL.lib,意在編譯時(shí)設(shè)定需要鏈接的DLL。
3.新建my_mysql新的PHP資源類型。
4.實(shí)現(xiàn)PHP API,供給PHP接口使用。
5.編譯擴(kuò)展,拷貝生成的php_my_mysql.dll到PHP_ROOT/ext下,并修改php.ini,增加extension=ext/php_my_mysql.dll。
6.編寫PHP文件,調(diào)用擴(kuò)展中提供的函數(shù)并調(diào)試。
@MYSQL_ROOT:表示mysql的安裝路徑
@PHP_ROOT:表示php所在路徑
三、開(kāi)始編碼
ext/my_mysql/php_my_mysql.h
/* $Id$ */
#ifndef PHP_MY_MYSQL_H
#define PHP_MY_MYSQL_H
extern zend_module_entry my_mysql_module_entry;
#define phpext_my_mysql_ptr &my_mysql_module_entry
#ifdef PHP_WIN32
# define PHP_MY_MYSQL_API __declspec(dllexport)
#elif defined(__GNUC__) && __GNUC__ >= 4
# define PHP_MY_MYSQL_API __attribute__ ((visibility("default")))
#else
# define PHP_MY_MYSQL_API
#endif
#ifdef ZTS
#include "TSRM.h"
#endif
PHP_MINIT_FUNCTION(my_mysql);
PHP_MSHUTDOWN_FUNCTION(my_mysql);
PHP_RINIT_FUNCTION(my_mysql);
PHP_RSHUTDOWN_FUNCTION(my_mysql);
PHP_MINFO_FUNCTION(my_mysql);
PHP_FUNCTION(my_mysql_connect);
PHP_FUNCTION(my_mysql_close);
PHP_FUNCTION(my_mysql_get_conn);
PHP_FUNCTION(my_mysql_select_db);
PHP_FUNCTION(my_mysql_ping);
PHP_FUNCTION(my_mysql_query);
PHP_FUNCTION(my_mysql_fetch_assoc);
PHP_FUNCTION(my_mysql_get_insert_id);
/*
Declare any global variables you may need between the BEGIN
and END macros here:
*/
ZEND_BEGIN_MODULE_GLOBALS(my_mysql)
long max_connection;
long default_connection;
char *driver_name;
char *host;
char *pwd;
char *user;
long port;
ZEND_END_MODULE_GLOBALS(my_mysql)
/* In every utility function you add that needs to use variables
in php_my_mysql_globals, call TSRMLS_FETCH(); after declaring other
variables used by that function, or better yet, pass in TSRMLS_CC
after the last function argument and declare your utility function
with TSRMLS_DC after the last declared argument. Always refer to
the globals in your function as MY_MYSQL_G(variable). You are
encouraged to rename these macros something shorter, see
examples in any other php module directory.
*/
#ifdef ZTS
#define MY_MYSQL_G(v) TSRMG(my_mysql_globals_id, zend_my_mysql_globals *, v)
#else
#define MY_MYSQL_G(v) (my_mysql_globals.v)
#endif
#endif /* PHP_MY_MYSQL_H */
// $mysql = my_mysql_connect("localhost", "root", "", "test", 3306);
// var_dump($mysql);
// // my_mysql_close($mysql);
// sleep(10);
$conn = array();
$conn[] = my_mysql_get_conn();
$conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// $conn[] = my_mysql_get_conn();
// print_r($conn);
var_dump($conn[0]);
// my_mysql_select_db($conn[0], "test");
// mysql_query("show processlist", $conn[0]);
// print_r($status);
// sleep(1);
my_mysql_select_db($conn[0], "mysql");
// sleep(1);
my_mysql_select_db($conn[1], "test");
my_mysql_ping($conn[1]);
$result = my_mysql_query($conn[1], "select * from test");
var_dump($result);
$arr = my_mysql_fetch_assoc($result);
my_mysql_query($conn[1], "INSERT INTO test VALUES(id, 'abc')");
$insert_id = my_mysql_get_insert_id($conn[1]);
print_r($arr);
echo $insert_id;
新聞熱點(diǎn)
疑難解答
圖片精選