php中有没有什么方法可以实现实时监听数据库中的某张表的变化

最好的办法是，在应用程序生命周期内，对于数据库设置有事件钩子，用于监听程序对于数据库的 *** 作。这样非常方便处理逻辑流程。

1 - 表的数据变化

表数据发生了变化，毫无疑问是写 *** 作，包括以下几种情形：

新建条目 create

更新条目 update

删除条目 delete

以上三种都是写 *** 作，会对表数据写入。

2 - 事件钩子

既然需要实时监控，那么每个数据库的 *** 作，都需要考虑在内，这是全局的监听。

以laravel的Eloquent ORM 模型触发事件，允许你挂接到模型生命周期的如下节点： retrieved、creating、created、updating、updated、saving、saved、deleting、deleted、restoring 和 restored。事件允许你每当特定模型保存或更新数据库时执行代码。每个事件通过其构造器接受模型实例。

模型内添加事件监听钩子

如果重用率很高，那么使用观察者 Observer 方式进行监听更为高效。

Laravel Observer

结语

上面的方法要求读者有laravel框架的使用基础，对于构建中大型应用非常有利。

一、读/写连接

有时您可能希望使用一个SELECT语句的数据库连接,,另一个用于插入、更新和删除语句。Laravel使这微风,将始终使用正确的连接是否使用原始查询,查询生成器或雄辩的ORM。

如何读/写连接应该配置,让我们看看这个例子:

复制代码 代码如下:

'mysql' =>array('read' =>array('host' =>'192.168.1.1'),'write' =>array('host' =>'196.168.1.2'),'driver' =>'mysql','database' =>'database','username' =>'root','password' =>'','charset' =>'utf8','collation' =>'utf8_unicode_ci','prefix' =>'')

注意,两个键添加到配置阵列:读和写。这两个键有数组值包含一个关键:主机。其余的读写数据库选项从主mysql连接将合并后的数组。所以,我们只需要将物品放入读取和写入数组如果我们希望覆盖主要数组中的值。所以,在这种情况下,192.168.1.1将被用作“读”连接,while192.168.1.2将被用作“写”连接。数据库凭证、前缀、字符集和所有其他选项在主mysql数组将跨两个共享连接。

二、运行查询

一旦你已经配置了数据库连接,你可以使用DB运行查询类。

运行一个Select查询

复制代码 代码如下:

$results = DB::select('select * from users where id = ?', array(1))

结果的选择方法总是返回一个数组。

运行一个Insert语句

复制代码 代码如下:

DB::insert('insert into users (id, name) values (?, ?)', array(1, 'Dayle'))

运行一个更新语句

复制代码 代码如下:

DB::update('update users set votes = 100 where name = ?', array('John'))

运行一个Delete语句

复制代码 代码如下:

DB::delete('delete from users')

注意:update和delete语句返回的行数的影响 *** 作。

运行一个通用声明

复制代码 代码如下:

DB::statement('drop table users')

查询事件监听

你可以查询事件监听使用DB::听方法:

复制代码 代码如下:

DB::listen(function($sql, $bindings, $time){ //})

三、数据库事务

运行在一个数据库事务的一组 *** 作,您可以使用事务方法:

复制代码 代码如下:

DB::transaction(function(){ DB::table('users')->update(array('votes'

=>1))DB::table('posts')->delete()})

注意:在事务抛出的任何异常关闭将导致自动事务将回滚

有时你可能需要开始一个事务:

复制代码 代码如下:

DB::beginTransaction()

你可以通过回滚事务回滚方法:

复制代码 代码如下:

DB::rollback()

最后,您可以通过提交方法:提交一个事务

复制代码 代码如下:

DB::commit()

四、访问连接

当使用多个连接,你可以访问它们通过DB::连接方法:

复制代码 代码如下:

$users = DB::connection('foo')->select(...)

你也可以访问原始的、潜在的PDO实例:

复制代码 代码如下:

$pdo = DB::connection()->getPdo()

有时你可能需要重新连接到一个给定的数据库:

复制代码 代码如下:

DB::reconnect('foo')

如果你需要断开从给定的数据库将超过底层PDO实例'smax_connections限制,使用断开连接方法:

复制代码 代码如下:

DB::disconnect('foo')

五、查询日志

默认情况下,Laravel日志保存在内存的所有查询运行当前的请求。然而,在某些情况下,例如当插入的行数,这可能会导致应用程序使用多余的内存。禁用日志,你可以使用disableQueryLog方法:

复制代码 代码如下:

DB::connection()->disableQueryLog()

o得到一组执行的查询,您可以使用getQueryLog方法:

复制代码 代码如下:

$queries = DB::getQueryLog()

配置完数据库连接，就可以使用DB类进行查询了。

查询

$results = DB::select('select * from users where id = ?', array(1))

select方法会以数组形式返回查询结果。

插入

DB::insert('insert into users (id, name) values (?, ?)', array(1, 'Dayle'))

更新

DB::update('update users set votes = 100 where name = ?', array('John'))

删除

DB::delete('delete from users')

注意：update和delete语句返回受影响的行数。

通用语句

DB::statement('drop table users')

监听Query事件

DB::listen(function($sql, $bindings, $time)

{

//

})

数据库事务

DB::transaction(function()

{

DB::table('users')->update(array('votes' =>1))

DB::table('posts')->delete()

})

注意：transaction闭包中的任何异常将会导致事务自动回滚。

有时候也许你想自己开启事务：

DB::beginTransaction()

你也可以自己回滚事务：

DB::rollback()

最后，你可以通过commit方法提交事务：

DB::commit()

多个数据库连接访问

当使用多个数据库连接时，可以通过DB::connection方法访问它们：

$users = DB::connection('foo')->select(...)

你可以通过PDO实例访问原生连接：

$pdo = DB::connection()->getPdo()

有时候你需要重连数据库：

DB::reconnect('foo')

如果因为超出PDO实例的最大连接数限制而要断开连接，使用disconnect方法：

DB::disconnect('foo')

查询日志

默认情况下，Laravel使用日志记录当前请求的所有数据库查询 *** 作，但是某些时候，比如插入大量数据，会引起应用使用过量内存。为了关闭日志，可以使用disableQuery方法：

DB::connection()->disableQueryLog()

获取查询日志记录，可以用过getQuery方法：

$queries = DB::getQueryLog()

---