程序人生网站首页 程序人生

workerman常用组件-MySQL组件-workerman之使用Workerman-MySQL - 具体MySQL的Connection用法-獲取一列數據

发布时间：2021-12-21 22:52:57编辑：雪饮阅读（）

實例：

<?php

use Workerman\Worker;

use Workerman\Connection\TcpConnection;

require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('websocket://0.0.0.0:8484');

$worker->onWorkerStart = function($worker)

{

global $db;

// 初始化db连接

$db = new \Workerman\MySQL\Connection('127.0.0.1', '3306', 'xy', 'xy', 'workerman');

};

$worker->onMessage = function(TcpConnection $connection, $data)

{

global $db;

$response=[];

// 获取一列数据

$response["col1"]=$db->select('ID')->from('phome_ecms_news_data_1')->where('newstext= :newstext')->bindValues(array('newstext'=>'雪饮'))->column();

//等价于

$response["col2"]=$db->select('ID')->from('phome_ecms_news_data_1')->where("newstext= '雪饮'")->column();

//等价于

$response["col3"]=$db->column("SELECT `ID` FROM `phome_ecms_news_data_1` WHERE newstext='雪饮'");

$connection->send(json_encode($response));

};

// 运行worker

Worker::runAll();

實例運行：

[root@localhost www.fpm.com]# /usr/local/php734/bin/php channelServer.php start

Workerman[channelServer.php] start in DEBUG mode

------------------------------------------- WORKERMAN --------------------------------------------

Workerman version:4.0.22 PHP version:7.3.4

-------------------------------------------- WORKERS ---------------------------------------------

proto user worker listen processes status

tcp root none websocket://0.0.0.0:8484 1 [OK]

--------------------------------------------------------------------------------------------------

Press Ctrl+C to stop. Start success.

关键字词：Workerman,MySQL,Connection,一列