swoole学习之mysql增删改查事务

ゝ一世哀愁。 2022-12-21 03:27 249阅读 0赞

### swoole学习之mysql增删改查事务 ###

*   *  第一步：配置
     *  第二步：查询
     *  第三步：增加
     *  第四步：编辑
     *  第五步：删除
     *  第六步：事务

## 第一步：配置 ##

<?php
    
    class MysqlService
    { 
    
        //定义一个变量
        public $dbSource = '';
        public $dbConfig = '';
        //定义构造函数
        public function __construct()
        { 
            Co\run(function () { 
                //实例化mysql服务
                $this->dbSource = new Swoole\Coroutine\MySQL();
                //配置mysql参数
                $this->dbConfig = array(
                    'host' => '127.0.0.1',
                    'port' => '3306',
                    'user' => 'root',
                    'password' => '123456',
                    'database' => 'qipa250',
                    'charset' => 'utf8',
                );       
            });
        }
    }
    
    //实例化类
    $mysql = new MysqlService();

## 第二步：查询 ##

//查询方法
        public function select($id)
        { 
            // 连接
            go(function () use ($id) { 
                $stmt = $this->dbSource->prepare('select * from qipa_member where id =?');
                echo "<pre>";
                print_r($stmt);
                if ($stmt == false) { 
                    var_dump($this->dbSource->errno, $this->dbSource->error);
                } else { 
                    $ret2 = $stmt->execute(array($id));
                    echo "<pre>";
                    print_r($ret2);
                }
                // 关闭连接
                $this->dbSource->close();
            });
        }

在类实例化后调用select方法

$id = 1;
    $mysql->select($id);

数据库中的数据  
![在这里插入图片描述][20201114150427963.png_pic_center]执行

> php mysqlService.php

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center]

## 第三步：增加 ##

//增加
        public function add($params)
        { 
    
            Co\run(function () use ($params) { 
    
                echo "<pre>";
                print_r($params);
    
                $now = date('Y-m-d H:i:s', time());
    
                echo $sql = 'insert into qipa_member value(null,"' . $params['member_name'] . '","' . $params['member_phone'] . '","' . $now . '","' . $now . '")';
    
                $this->dbSource->connect($this->dbConfig);
    
                $res = $this->dbSource->query($sql);
                if ($res === false) { 
                    return;
                }
            });
        }

定义要增加的内容

$member_data = array(
        'member_name' => '奇葩',
        'member_phone' => 'qipaqipa'
    );
    $mysql->add($member_data);

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 1]  
数据库中查看，添加成功  
![在这里插入图片描述][20201114150659184.png_pic_center]

## 第四步：编辑 ##

//修改
        public function edit($params)
        { 
            Co\run(function () use ($params) { 
    
                echo "<pre>";
                print_r($params);
    
                echo $sql = ' update qipa_member set member_name="' . $params['member_name'] . '",member_phone="' . $params['member_phone'] . '" where id =' . $params['id'];
    
                $this->dbSource->connect($this->dbConfig);
    
                $res = $this->dbSource->query($sql);
                //打印结果
                var_dump($res);
                //如果是false，表示出错
                if ($res === false) { 
                    //打印报错原因
                    var_dump($this->dbSource->errno, $this->dbSource->error);
                    return;
                }
            });
        }

定义要修改的内容和指定id

$member_edit = array(
        'id' => 1,
        'member_name' => '奇葩天地网',
        'member_phone' => 'www.qipa250.com'
    );
    $mysql->edit($member_edit);

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 2]数据库的字段设置的长度不够，修改数据库结构  
原有的  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 3]改成现有的  
![在这里插入图片描述][20201114151329517.png_pic_center]再去执行  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 4]会看到true，再查询数据库中

![在这里插入图片描述][20201114151424157.png_pic_center]  
修改成功

## 第五步：删除 ##

//删除指定id的数据
        public function delete($id)
        { 
            Co\run(function () use ($id) { 
    
    
                echo $sql = ' delete from qipa_member where id =' . $id;
                echo PHP_EOL;
                $this->dbSource->connect($this->dbConfig);
    
                $res = $this->dbSource->query($sql);
                var_dump($res);
                if ($res === false) { 
                    //打印报错原因
                    var_dump($this->dbSource->errno, $this->dbSource->error);
                    return;
                }
            });
        }

传入错误的值

$id = '4i4';
    $mysql->delete($id);

打印报错  
![在这里插入图片描述][20201114151742726.png_pic_center]![在这里插入图片描述][20201114151800672.png_pic_center]数据库中有三条记录，我们把id=4的记录删掉

传入正确的值

$id = 4;
    $mysql->delete($id);

![在这里插入图片描述][20201114151847976.png_pic_center]  
数据库中已经删掉id=4的记录  
![在这里插入图片描述][20201114151856169.png_pic_center]

## 第六步：事务 ##

数据库中用户1和用户2，各有100元  
操作：将id等于1的用户钱减少50元，值为50，id等于2的用增加50,值为150 若是失败，则回滚  
![在这里插入图片描述][20201114153303186.png_pic_center]

事务方法

//事务
        public function transaction($edit_data)
        { 
            Co\run(function () use ($edit_data) { 
    
                //数据库中用户1和用户2，各有100元
                //操作：将id等于1的用户钱减少50元，值为50，id等于2的用增加50,值为150
                //链接数据库
                $this->dbSource->connect($this->dbConfig);
                //开始事务
                $this->dbSource->begin();
    
    
                echo $sql_from = ' update qipa_money set money=50 where member_id =' . $edit_data['from_id'];
                echo PHP_EOL;
    
                echo $sql_to = ' update qipa_money set money="www.qipa250.com" where member_id =' . $edit_data['to_id'];
                echo PHP_EOL;
    
                //执行第一条数据
                $res_from = $this->dbSource->query($sql_from);
                var_dump($res_from);
                if ($res_from === false) { 
                    //打印报错原因
                    var_dump($this->dbSource->errno, $this->dbSource->error);
                    //如果报错，回滚数据
                    $this->dbSource->rollback();
                    return;
                }
    
                //执行第二条数据
                $res_to = $this->dbSource->query($sql_to);
                var_dump($res_to);
                if ($res_to === false) { 
                    //打印报错原因
                    var_dump($this->dbSource->errno, $this->dbSource->error);
                    //如果报错，回滚数据
                    $this->dbSource->rollback();
                    return;
                }
    
                //提交数据
                $this->dbSource->commit();
    
    
            });
        }

执行报错，发现第一条执行成功，true，第二条返回false失败，并打印了失败原因  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 5]  
查询数据库中 发现并没有变化  
![在这里插入图片描述][20201114153602493.png_pic_center]

我们将第二条sql语句修改正确

echo $sql_to = ' update qipa_money set money=150 where member_id =' . $edit_data['to_id'];

再去执行命令  
![在这里插入图片描述][20201114153646290.png_pic_center]发现两条数据都返回成功，查看数据库中

![在这里插入图片描述][20201114153718578.png_pic_center]  
发现已经更新成功

[20201114150427963.png_pic_center]: /images/20221120/14788c176d7c48d29a44c23e262ee72b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/484f6190975f40e6b70be1902bd0c5ab.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/6b7b8a041b8042d6830c879ff340f7ba.png
[20201114150659184.png_pic_center]: /images/20221120/285533c354b248159db34e5454cda172.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/eaaa6311c2af4711ad4239a32be535fe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/a5c32940c8aa46f9bcdfddf4070627c7.png
[20201114151329517.png_pic_center]: /images/20221120/9ce65ea4af2b484f97a7df50e3553842.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221120/18528b14d58045e1ae5cc83387fc3b30.png
[20201114151424157.png_pic_center]: /images/20221120/8a2fc5b239454ee7b89860c3dcf97946.png
[20201114151742726.png_pic_center]: https://img-blog.csdnimg.cn/20201114151742726.png#pic_center
[20201114151800672.png_pic_center]: /images/20221120/320096917d6c4456b01adcadbe524683.png
[20201114151847976.png_pic_center]: /images/20221120/c2c486f0467c4c9dadd1754bbf004ff8.png
[20201114151856169.png_pic_center]: /images/20221120/f6a3fe7de6c34a6cae3e3f5fcf298de8.png
[20201114153303186.png_pic_center]: /images/20221120/a9e83e14df98474cb0c477dc4dff8dd6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2d1b19xaWFuZ3FpYW5n_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221120/d2bc95f71b844f53909963530f288697.png
[20201114153602493.png_pic_center]: /images/20221120/055f4338f4f1478bb7898210aa16f07b.png
[20201114153646290.png_pic_center]: /images/20221120/d41499c8f99c4eedb15b43c16aa23a14.png
[20201114153718578.png_pic_center]: https://img-blog.csdnimg.cn/20201114153718578.png#pic_center