. */ Doctrine::autoload('Doctrine_Sequence'); /** * Doctrine_Sequence_Sqlite * * @package Doctrine * @author Konsta Vesterinen * @license http://www.opensource.org/licenses/lgpl-license.php LGPL * @category Object Relational Mapping * @link www.phpdoctrine.com * @since 1.0 * @version $Revision$ */ class Doctrine_Sequence_Sqlite extends Doctrine_Sequence { /** * Returns the next free id of a sequence * * @param string $seqName name of the sequence * @param bool $onDemand when true missing sequences are automatic created * * @return integer next id in the given sequence */ public function nextId($seqName, $onDemand = true) { $sequenceName = $this->conn->quoteIdentifier($this->conn->getSequenceName($seqName), true); $seqcolName = $this->conn->quoteIdentifier($this->conn->getAttribute(Doctrine::ATTR_SEQCOL_NAME), true); $query = 'INSERT INTO ' . $sequenceName . ' (' . $seqcolName . ') VALUES (NULL)'; try { $this->conn->exec($query); } catch(Doctrine_Connection_Exception $e) { if ($onDemand && $e->getPortableCode() == Doctrine::ERR_NOSUCHTABLE) { // Since we are creating the sequence on demand // we know the first id = 1 so initialize the // sequence at 2 try { $result = $this->conn->export->createSequence($seqName, 2); } catch(Doctrine_Exception $e) { throw new Doctrine_Sequence_Exception('on demand sequence ' . $seqName . ' could not be created'); } // First ID of a newly created sequence is 1 return 1; } } $value = $this->conn->getDbh()->lastInsertID(); if (is_numeric($value)) { $query = 'DELETE FROM ' . $sequenceName . ' WHERE ' . $seqcolName . ' < ' . $value; $this->conn->exec($query); /** TODO: is the following needed ? if (PEAR::isError($result)) { $this->warnings[] = 'nextID: could not delete previous sequence table values from '.$seq_name; } */ } return $value; } /** * Returns the autoincrement ID if supported or $id or fetches the current * ID in a sequence called: $table.(empty($field) ? '' : '_'.$field) * * @param string name of the table into which a new row was inserted * @param string name of the field into which a new row was inserted * @return integer|boolean */ public function lastInsertId($table = null, $field = null) { return $this->conn->getDbh()->lastInsertID(); } /** * Returns the current id of a sequence * * @param string $seqName name of the sequence * * @return integer current id in the given sequence */ public function currId($seqName) { $sequenceName = $this->conn->quoteIdentifier($this->conn->getSequenceName($seqName), true); $seqcolName = $this->conn->quoteIdentifier($this->conn->getAttribute(Doctrine::ATTR_SEQCOL_NAME), true); $query = 'SELECT MAX(' . $seqcolName . ') FROM ' . $sequenceName; return (int) $this->conn->fetchOne($query); } }