66     protected $connection;  variable in Auth_OpenID_SQLStore
79      * @param Auth_OpenID_DatabaseConnection $connection This must be an established
93     function __construct($connection, $associations_table = null, $nonces_table = null)  argument
100         if (!(is_object($connection) &&
101               (is_subclass_of($connection, 'db_common') ||
102                is_subclass_of($connection,
105                           "object (got ".get_class($connection).")",
110         $this->connection = $connection;
117         if (is_subclass_of($this->connection, 'db_common')) {
118             $this->connection->setFetchMode(DB_FETCHMODE_ASSOC);
136         $this->connection->autoCommit(false);
171                       $this->connection->query(
214         $this->connection->query(sprintf("DELETE FROM %s",
217         $this->connection->query(sprintf("DELETE FROM %s",
304         $this->connection->autoCommit(true);
307         $this->connection->autoCommit(false);
319             $r = $this->connection->query($this->sql['nonce_table']);
328             $r = $this->connection->query($this->sql['assoc_table']);
347         return $this->connection->query($this->sql['set_assoc'],
369             $this->connection->commit();
371             $this->connection->rollback();
383         $result = $this->connection->getRow($this->sql['get_assoc'],
399         $result = $this->connection->getAll($this->sql['get_assocs'],
415         if ($this->resultToBool($this->connection->query(
418             $this->connection->commit();
420             $this->connection->rollback();
490         $result = $this->connection->query($sql, [
496             $this->connection->rollback();
498             $this->connection->commit();
580         $this->connection->query($this->sql['clean_nonce'], [$v]);
581         $num = $this->connection->affectedRows();
582         $this->connection->commit();
588         $this->connection->query($this->sql['clean_assoc'], [time()]);
589         $num = $this->connection->affectedRows();
590         $this->connection->commit();