PHP开发学习[7]——代码实现主从数据库读写分离

header(&＃39;Content-Type: text/html;charset &＃61; utf-8 &＃39;);
/*** User: zhanghj*/
define("DB_HOST_1","192.168.1.73");//请正确对应 IP 地址 用户名 密码 即可...
define("DB_USER_1","momomo");
define("DB_PWD_1","000000");define("DB_HOST_2","192.168.1.74");
define("DB_USER_2","nonono");
define("DB_PWD_2","000000");define("DB_DBNAME","minsheng");
define("DB_CHARSET","utf8");/*** 思路&＃xff1a;根据传入的sql语句&＃xff0c;判断是否为查询操作 此处使用 mysql* &＃64;param $sql 执行的SQL语句* &＃64;return resource*/
function connectTo($sql){$link &＃61; null;$querystr &＃61; trim($sql);$querystr &＃61; substr($querystr,0,6);if($querystr !&＃61; &＃39;select&＃39;){//如果不是查询语句就连接主服务器$link&＃61;&＃64;mysql_connect(DB_HOST_1,DB_USER_1,DB_PWD_1)or die("主库连接失败Error:".mysql_errno().":".mysql_error());print_r(&＃39;主库连接成功&＃39;);}else{//如果是查询语句就连接从服务器$link&＃61;&＃64;mysql_connect(DB_HOST_2,DB_USER_2,DB_PWD_2)or die("从库连接失败Error:".mysql_errno().":".mysql_error());print_r(&＃39;从库连接成功&＃39;);}mysql_set_charset(DB_CHARSET);//mysql_query(&＃39;set names utf8&＃39;);mysql_select_db(DB_DBNAME) or die("指定数据库打开失败");return $link;
}/*** 完成记录插入的操作* &＃64;param string $table* &＃64;param array $array* &＃64;return number*/
function insert($table,$array){$keys&＃61;join(",",array_keys($array));$vals&＃61;"&＃39;".join("&＃39;,&＃39;",array_values($array))."&＃39;";$sql&＃61;"insert {$table}($keys) values({$vals})";$link &＃61; connectTo($sql);mysql_query($sql);$Tag_id &＃61; mysql_insert_id();//根据需求 关闭连接mysql_close($link);return $Tag_id;
}function getResultNum($sql){$link &＃61; connectTo($sql);$result&＃61;mysql_query($sql);$Tag_num &＃61; mysql_num_rows($result);//根据需求 关闭连接mysql_close($link);return $Tag_num;
}/*使用提示:运行SQL语句前&＃xff0c;首先调用connectTo($sql)方法&＃xff0c;进行数据库链接的选择根据自己的项目需求&＃xff0c;判断是否断开上述方法返回的连接
*///测试&＃xff1a;
$data &＃61; array(&＃39;user_name&＃39; &＃61;> &＃39;wo&＃xffe5;&＃xffe5; 的名字&＃39;,&＃39;email&＃39; &＃61;> &＃39;爱谁谁&＃xff01;别关心那么多&＃xff0c;好嘛&＃xff1f;&＃39;
);echo &＃39;我在测试呢&＃xff01;&＃39;;
$tag &＃61;insert(&＃39;ms_users&＃39;,$data);
echo $tag;
echo &＃39;

/*** 思路&＃xff1a;根据传入的sql语句&＃xff0c;判断是否为查询操作 此处使用 mysqli* 前提是&＃xff0c;开启mysqli的扩展功能* &＃64;param $sql 执行的SQL语句* &＃64;return resource*/
function connectTo($sql){$mysqli &＃61; null;$querystr &＃61; trim($sql);$querystr &＃61; substr($querystr,0,6);//使用 mysqli 面向对象方式进行数据库的连接操作if($querystr !&＃61; &＃39;select&＃39;){//如果不是查询语句就连接主服务器//创建对象并打开连接&＃xff0c;最后一个参数是选择的数据库名称$mysqli &＃61; new mysqli(DB_HOST_1,DB_USER_1,DB_PWD_1,DB_DBNAME);//检查连接是否成功if (mysqli_connect_errno()){die(&＃39;主库连接失败Error&＃xff1a;&＃39;). mysqli_connect_error();}print_r(&＃39;主库连接成功&＃39;);}else{//如果是查询语句就连接从服务器$mysqli &＃61; new mysqli(DB_HOST_2,DB_USER_2,DB_PWD_2,DB_DBNAME);//检查连接是否成功if (mysqli_connect_errno()){die(&＃39;从库连接失败Error:&＃xff1a;&＃39;). mysqli_connect_error();}print_r(&＃39;从库连接成功&＃39;);}$mysqli->query("set names &＃39;".DB_CHARSET."&＃39;");return $mysqli;
}