swoole apprentissage Mysql asynchrone-Swoole-php.cn

swoole apprentissage Mysql asynchrone

coldplay.xixi

Libérer： 2021-03-18 11:27:47

avant

2179 Les gens l'ont consulté

swoole apprentissage Mysql asynchrone

Exemple officiel :

$db = new swoole_mysql();$server = array(
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'test',
    'password' => 'test',
    'database' => 'test',
    'charset' => 'utf8', //指定字符集
    'timeout' => 2,  // 可选：连接超时时间（非查询超时时间），默认为SW_MYSQL_CONNECT_TIMEOUT（1.0）);$db->connect($server, function ($db, $result) {
    if ($result === false) {
        var_dump($db->connect_errno, $db->connect_error);
        die;
    }
    $sql = 'show tables';
    $db->query($sql, function(swoole_mysql $db, $result) {
        if ($result === false)
        {
            var_dump($db->error, $db->errno);
        }
        elseif ($result === true )
        {
            var_dump($db->affected_rows, $db->insert_id);
        }
        var_dump($result);
        $db->close();
    });});

Copier après la connexion

Recommandé (gratuit) : swoole

Fonctions communes :

`connect($config, $callback)` Se connecter à la base de données

$config= array(
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'test',
    'password' => 'test',
    'database' => 'test',
    'charset' => 'utf8', //指定字符集
    'timeout' => 2,  // 可选：连接超时时间（非查询超时时间），默认为SW_MYSQL_CONNECT_TIMEOUT（1.0）);

Copier après la connexion

host Adresse IP de l'hôte
portNuméro de port, par défaut 3306
user Nom d'utilisateur
passwordMot de passe
databaseBase de données sélectionnée
charsetDéfinir le jeu de caractères du client
timeout Délai d'expiration de la connexion, par défaut 1.0

$callbackFonction de rappelfunction($db, $result )

$db objet swoole_mysql
$result valeur de retour, quand elle est vraie Pour exécuter query, quand c'est false, vous pouvez obtenir le code d'erreur et les informations d'erreur via $db->connect_errno et $db->connect_error

`query($sql, $callback)` pour exécuter l'instruction SQL

$sql = "select * from test ";$db->query($sql,function($link,$result){});

Copier après la connexion

$sql est l'instruction SQL à exécuter
$callback fonction de rappel
Chaque connexion MySQLi ne peut exécuter qu'un seul SQL à la fois, et doit attendre le résultat de retour avant d'exécuter le SQL suivant

fonction de rappel function($link,$result)

Lorsque l'exécution SQL échoue, c'est-à-dire $result == false, le message d'erreur peut être obtenu via $link->error et le code d'erreur peut être obtenu via $link->errno
L'exécution est réussie, $result == true, via $link->affected_rowsObtenir le nombre de lignes concernées, $link->insert_idObtenir l'ID d'auto-incrémentation de l'insertopération
est exécuté avec succès et SQL est une instruction de requête, $result renvoie un tableau de résultats de requête

`close`Fermez la connexion

 $db->close();

Copier après la connexion

Fermez toute la connexion SQL

`on($event_name,$callback)`Fonction de rappel

Actuellement, il n'y en a qu'une seuleswoole_mysql 🎜>Fonction de rappelonClose
//mysql连接关闭时,自动触发$db->on('close',function($db){
	echo "mysql connection is closed";});
Copier après la connexion

Choses dans swoole_mysql

sont détaillés dans la documentation officielle :

Ouvrir les choses`begin(function($db,$result))`

transaction si la transaction est démarrée avec succès, la fonction spécifiée sera rappelée. MySQL
et commit pour implémenter rollback le traitement des transactions MySQL
objet de connexion ne peut démarrer qu'une seule transaction à en même temps MySQL
t ou commi pour continuer à démarrer une nouvelle transaction rollback
exception, l'exception SwooleMySQLException est code21

commit transaction `commit($callback)`

Vous doit d'abord appeler start pour démarrer la transaction avant d'appeler commit, sinon la couche inférieure lancera
ExceptionSwooleMySQLException
est code22

Thing rollback `rollback($callback)`

ExceptionSwooleMySQLException
est code 22

$db->begin(function( $db, $result) {
    $db->query("update userinfo set level = 22 where id = 1", function($db, $result) {
        $db->commit(function($db, $result) {
            echo "commit ok\n";
        });
    });});

Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!