zoukankan      html  css  js  c++  java
  • 异步MySQL客户端

    <?php
    /**
     * Created by PhpStorm.
     * User: baidu
     * Date: 18/3/11
     * Time: 下午10:40
     */
    class AysMysql {
        /**
         * @var string
         */
        public $dbSource = "";
        /**
         * mysql的配置
         * @var array
         */
        public $dbConfig = [];
        public function __construct() {
            //new swoole_mysql;
            $this->dbSource = new SwooleMysql;
    
            $this->dbConfig = [
                'host' => '127.0.0.1',
                'port' => 5123,
                'user' => 'root',
                'password' => 123456,
                'database' => 'swoole',
                'charset' => 'utf8',
            ];
        }
    
        public function update() {
    
        }
    
        public function add() {
    
        }
    
        /**
         * mysql 执行逻辑
         * @param $id
         * @param $username
         * @return bool
         */
        public function execute($id, $username) {
            // connect
            $this->dbSource->connect($this->dbConfig, function($db, $result) use($id, $username)  {
                echo "mysql-connect".PHP_EOL;
                if($result === false) {
                    var_dump($db->connect_error);
                    // todo
                }
    
                //$sql = "select * from test where id=1";
                $sql = "update test set `username` = '".$username."' where id=".$id;
                // insert into
                // query (add select update delete)
                $db->query($sql, function($db, $result){
                    // select => result返回的是 查询的结果内容
    
                    if($result === false) {
                        // todo
                        var_dump($db->error);
                    }elseif($result === true) {// add update delete
                        // todo
                        var_dump($db->affected_rows);
                    }else {
                        print_r($result);
                    }
                    $db->close();
                });
    
            });
            return true;
        }
    }
    $obj = new AysMysql();
    $flag = $obj->execute(1, 'singwa-111112');
    var_dump($flag).PHP_EOL;
    echo "start".PHP_EOL;
    
    for($i=0; $i<900000;$i++) {
        echo $i.PHP_EOL;
    }
    
    // 详情页 -》mysql(阅读数) -》msyql 文章 +1 -》页面数据呈现出来
    

      比如记录文章阅读数

  • 相关阅读:
    Android通知栏介绍与适配总结
    Java emoji持久化mysql
    css自适应
    常用网址总结
    前端开发常用技巧
    JAVA问题集锦Ⅰ
    Android之常见问题集锦Ⅱ
    Java集合之ConcurrentHashMap.addCount解析
    Java集合之ConcurrentHashMap解析
    Java数据结构之Map
  • 原文地址:https://www.cnblogs.com/sunlong88/p/8999164.html
Copyright © 2011-2022 走看看