问在PDO事务中创建表

EN

$userid = "123456";
$firstname = "Dae";
$oglang = "engs";
$status = 0; 

$pdo->beginTransaction();

try{





// Find a user with a status of 0 
    $sql = "SELECT id FROM users WHERE chattingstatus = :status";
    $stmt = $pdo->prepare($sql);
    $stmt->execute(array(':status' => $status)
    );
    $freeuser = $stmt->fetchColumn();


//put the original user into the database with userid firstname and language
 $sql = "INSERT INTO users (userid, firstname, oglang, chattingstatus) VALUES (:userid, :firstname, :oglang, :chattingstatus)";
    $stmt = $pdo->prepare($sql);
    $stmt->execute(array(':userid' => $userid, ':firstname' => $firstname, ':oglang' => $oglang, ':chattingstatus' => 0)
    );
   $ogID = $pdo->lastInsertId();




// change the chattingstatus of 0 of the free user to 1
    $sql = "UPDATE users SET chattingstatus = 1 WHERE id = :freeuser";
    $stmt = $pdo->prepare($sql);
    $stmt->execute(array(':freeuser' => $freeuser)
    );

//query 3  CHANGE STATUS OF ORIGINAL USER from 0 to 1 
    $sql = "UPDATE users SET chattingstatus = 1 WHERE userid = :oguser";
    $stmt = $pdo->prepare($sql);
    $stmt->execute(array(':oguser' => $userid)
    );

//query 4: Make a table between the 2 users with their IDs


    $table = $freeuser."+".$ogID; 

   $sql ="CREATE table $table(
     ID INT( 11 ) AUTO_INCREMENT PRIMARY KEY,
     Messages VARCHAR( 50 ) NOT NULL);";
    $stmt = $pdo->exec($sql);
     print("Created $table Table.\n");

     $pdo->commit();

} 
//Our catch block 
catch(Exception $e){

    //Print out the error message.
    echo $e->getMessage(); 

    //Rollback the transaction.
    $pdo->rollBack();
}