个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
28
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章thinkphp下MySQL数据库读写分离代码剖析由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
当采用原生态的sql语句进行写入操作的时候，要用execute，读操作要用query.
MySQL数据主从同步还是要靠MySQL的机制来实现，所以这个时候MySQL主从同步的延迟问题是需要优化，延迟时间太长不仅影响业务，还影响用户体验.
thinkphp核心类Thinkphp/library/Model.class.php 中，query 方法，调用Thinkphp/library/Think/Db/Driver/Mysql.class.php 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
/**
* SQL查询
* @access public
* @param string $sql SQL
* @param mixed $parse 是否需要解析SQL
* @return mixed
*/
public
function
query(
$sql
,
$parse
=false) {
if
(!
is_bool
(
$parse
) && !
is_array
(
$parse
)) {
$parse
= func_get_args();
array_shift
(
$parse
);
}
$sql
=
$this
->parseSql(
$sql
,
$parse
);
return
$this
->db->query(
$sql
);
}
|
调用Thinkphp/library/Think/Db/Driver/Mysql.class.php 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
/**
* 执行查询 返回数据集
* @access public
* @param string $str sql指令
* @return mixed
*/
public
function
query(
$str
) {
if
(0===
stripos
(
$str
,
'call'
)){
// 存储过程查询支持
$this
->close();
$this
->connected = false;
}
$this
->initConnect(false);
if
( !
$this
->_linkID )
return
false;
$this
->queryStr =
$str
;
//释放前次的查询结果
if
(
$this
->queryID ) {
$this
->free(); }
N(
'db_query'
,1);
// 记录开始执行时间
G(
'queryStartTime'
);
$this
->queryID = mysql_query(
$str
,
$this
->_linkID);
$this
->debug();
if
( false ===
$this
->queryID ) {
$this
->error();
return
false;
}
else
{
$this
->numRows = mysql_num_rows(
$this
->queryID);
return
$this
->getAll();
}
}
|
上面初始化数据库链接时，initConnect(false)，调用Thinkphp/library/Think/Db/Db.class.php,注意false、true代码实现。true表示直接调用主库，false表示调用读写分离的读库.
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
/**
* 初始化数据库连接
* @access protected
* @param boolean $master 主服务器
* @return void
*/
protected
function
initConnect(
$master
=true) {
if
(1 == C(
'DB_DEPLOY_TYPE'
))
// 采用分布式数据库
$this
->_linkID =
$this
->multiConnect(
$master
);
else
// 默认单数据库
if
( !
$this
->connected )
$this
->_linkID =
$this
->connect();
}
/**
* 连接分布式服务器
* @access protected
* @param boolean $master 主服务器
* @return void
*/
protected
function
multiConnect(
$master
=false) {
foreach
(
$this
->config
as
$key
=>
$val
){
$_config
[
$key
] =
explode
(
','
,
$val
);
}
// 数据库读写是否分离
if
(C(
'DB_RW_SEPARATE'
)){
// 主从式采用读写分离
if
(
$master
)
// 主服务器写入
$r
=
floor
(mt_rand(0,C(
'DB_MASTER_NUM'
)-1));
else
{
if
(
is_numeric
(C(
'DB_SLAVE_NO'
))) {
// 指定服务器读
$r
= C(
'DB_SLAVE_NO'
);
}
else
{
// 读操作连接从服务器
$r
=
floor
(mt_rand(C(
'DB_MASTER_NUM'
),
count
(
$_config
[
'hostname'
])-1));
// 每次随机连接的数据库
}
}
}
else
{
// 读写操作不区分服务器
$r
=
floor
(mt_rand(0,
count
(
$_config
[
'hostname'
])-1));
// 每次随机连接的数据库
}
$db_config
=
array
(
'username'
=> isset(
$_config
[
'username'
][
$r
])?
$_config
[
'username'
][
$r
]:
$_config
[
'username'
][0],
'password'
=> isset(
$_config
[
'password'
][
$r
])?
$_config
[
'password'
][
$r
]:
$_config
[
'password'
][0],
'hostname'
=> isset(
$_config
[
'hostname'
][
$r
])?
$_config
[
'hostname'
][
$r
]:
$_config
[
'hostname'
][0],
'hostport'
=> isset(
$_config
[
'hostport'
][
$r
])?
$_config
[
'hostport'
][
$r
]:
$_config
[
'hostport'
][0],
'database'
=> isset(
$_config
[
'database'
][
$r
])?
$_config
[
'database'
][
$r
]:
$_config
[
'database'
][0],
'dsn'
=> isset(
$_config
[
'dsn'
][
$r
])?
$_config
[
'dsn'
][
$r
]:
$_config
[
'dsn'
][0],
'params'
=> isset(
$_config
[
'params'
][
$r
])?
$_config
[
'params'
][
$r
]:
$_config
[
'params'
][0],
'charset'
=> isset(
$_config
[
'charset'
][
$r
])?
$_config
[
'charset'
][
$r
]:
$_config
[
'charset'
][0],
);
return
$this
->connect(
$db_config
,
$r
);
}
|
query方法参数为false,其他删除、更新、增加读主库。这一点可以结合Thinkphp/library/Model.class.php中的delete、save、add操作，参数为true.
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我.
原文链接：https://segmentfault.com/a/1190000009090079 。
最后此篇关于thinkphp下MySQL数据库读写分离代码剖析的文章就讲到这里了,如果你想了解更多关于thinkphp下MySQL数据库读写分离代码剖析的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
28
4
0
我的 Django 应用程序在生产过程中变得非常缓慢。可能是由于某些复杂或未索引的查询。 是否有任何类似 django 的方法来分析我的应用程序？ 最佳答案 试试 Django Debug Toolb
我正在使用GDownloadUrl将客户端数据发送到服务器。这里是我使用的sode GDownloadUrl( dwnld_url, function(data) {
我一直在尝试开始分析我的 CherryPy 网络服务器，但文档缺乏关于如何设置它的详细信息。我知道我应该能够使用 cherrypy.lib.profiler 作为中间件来安装我的初始服务器。现在，我有
是否有任何 HashMap 实现公开了用于分析 Map 性能的钩子(Hook)方法(平均链长度、最佳/最差/平均访问时间、#rehashes 等)。 在 ~O(1) 访问时间方面使用 HashMap
我想知道是否有可用的技术或工具可以告诉您执行特定方法需要多少时间。 类似于数学/计算机科学中的大 O 符号，可以让您了解算法的复杂性，我想知道代码分析是否有类似的东西。 最佳答案 Profiling是
前面,我们说Ruby没有函数,只有方法.而且实际上有不止一种方法.这一节我们介绍访问控制(accesscontrols). 想想当我们在"最高层"而不是在一个类的定义里定义一个
我有一个用 Visual Basic 编写的大型应用程序6，我需要分析它。有没有类似 ANTS Profiler 的东西但对于 COM应用程序？ 最佳答案 我以前用 VBWatch .我对它有很好的体
我做了两个实现来解决 Shikaku 难题。一个使用顶部、左侧、宽度和高度 (TLWH) 作为每个矩形的参数，另一个使用顶部、左侧、底部、右侧 (TLBR)。 出于某种原因，使用 TLBR 的速度要快
如果重要的话，我正在使用 Very Sleepy CS 进行分析。 IPP(Intel's Integrated Performance Primitives)在我的项目中使用，基本上是单次调用: i
我想弄明白这个排列算法是如何工作的: def perm(n, i): if i == len(n) - 1: print n else: for j i
如果 C++ 项目的物理结构有利于编译速度，您将如何获得某种客观的衡量标准？有些人说你应该避免使用模板以获得更好的编译速度，但是如果模板生成大量非冗余目标代码，即使行/秒编译速度不是很好，那也不是很糟
摘自 Robert Sedgewick 和 Kevin Wayne 算法第 4 版 在递归部分基本情况代码是 if(end start) { mid = (start+end
有没有一种简单的方法可以计算一段标准 C 代码实际执行的乘法次数？我想到的代码基本上只是做加法和乘法，主要兴趣是乘法，但也可以计算其他操作的数量。 如果这是一个选项，我想我可以四处用“multiply
我正在编写一个 Netty 应用程序。该应用程序运行在 64 位八核 linux 机器上 Netty 应用程序是一个简单的路由器，它接受请求(传入管道)，从请求中读取一些元数据并将数据转发到远程服务(
我希望能得到一些帮助来弄清楚这个异常消息到底对我说了什么。我能够使用调试器将问题缩小到代码中的特定行。但是，我认为更多信息可以更好地找出代码中的实际问题。 public static List
我有一个存储在 USB 拇指驱动器上的 mysql 数据库，该数据库已不可挽回地丢失了其文件分配表。因此，我无法访问整个 ibdata1 文件。不过，我可以找到使用十六进制编辑器使用的记录页面。 所有
我正在使用 jQuery 在单击时显示图像。通过将图像源存储到像这样的变量中，这可以很好地工作.. var theSrc = $(event.target).attr('src'); 然后我可以将这张
我是 R 的新手，但不是 C 的新手。我想看看是否可以为 friend 加速一个包。通常使用 C 我会编译一个设置了 -pg 标志的应用程序，然后将 gmon.out 文件传递给 gprof。 我
在分析我的代码以找出运行缓慢的地方时，我有 3 个功能显然会永远占用，这就是非常困的说法。 这些函数是: ZwDelayExecution 20.460813 20.460813 19.
我正在分析一个应用程序并注意到 52% (195MB) 的内存被 char[] 使用，20% 被 String 使用。这是一个有很多依赖项的大型项目，我刚刚看到它，所以我有几个相关的问题可以帮助我开始
我是一名优秀的程序员,十分优秀！