RetailCRM-Mirror/doctrine2
1
0
Fork 0
mirror of synced 2025-04-03 13:23:37 +03:00
Code Issues Projects Releases Wiki Activity

Browse source
This commit is contained in:
zYne 2007-01-08 11:12:53 +00:00
parent 4928dfef8c
commit fc4261d1f7
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
lib/Doctrine/Sequence/Pgsql.php
View file

@ -42,18 +42,18 @@ class Doctrine_Sequence_Pgsql extends Doctrine_Sequence
*/ */
public function nextId($seqName, $onDemand = true) public function nextId($seqName, $onDemand = true)
{ {
$sequenceName = $this->conn->quoteIdentifier($this->getSequenceName($seqName), true); $sequenceName = $this->conn->quoteIdentifier($this->conn->getSequenceName($seqName), true);
$query = "SELECT NEXTVAL('" . $sequenceName . "')"; $query = "SELECT NEXTVAL('" . $sequenceName . "')";
try { try {
$result = $this->fetchOne($query, 'integer'); $result = (int) $this->fetchOne($query);
} catch(Doctrine_Connection_Exception $e) { } catch(Doctrine_Connection_Exception $e) {
if ($onDemand && $e->getPortableCode() == Doctrine::ERR_NOSUCHTABLE) { if ($onDemand && $e->getPortableCode() == Doctrine::ERR_NOSUCHTABLE) {
try { try {
$result = $this->conn->export->createSequence($seqName); $result = $this->conn->export->createSequence($seqName);
} catch(Doctrine_Exception $e) { } catch(Doctrine_Exception $e) {
throw new Doctrine_Sequence_Sqlite_Exception('on demand sequence ' . $seqName . ' could not be created'); throw new Doctrine_Sequence_Exception('on demand sequence ' . $seqName . ' could not be created');
} }
return $this->nextId($seqName, false); return $this->nextId($seqName, false);
} }
@ -70,9 +70,9 @@ class Doctrine_Sequence_Pgsql extends Doctrine_Sequence
public function lastInsertId($table = null, $field = null) public function lastInsertId($table = null, $field = null)
{ {
$seq = $table.(empty($field) ? '' : '_'.$field); $seq = $table.(empty($field) ? '' : '_'.$field);
$sequenceName = $this->conn->quoteIdentifier($this->getSequenceName($seqName), true); $sequenceName = $this->conn->quoteIdentifier($this->conn->getSequenceName($seqName), true);
return $this->fetchOne("SELECT currval('" . $sequenceName . "')", 'integer'); return (int) $this->fetchOne("SELECT CURRVAL('" . $sequenceName . "')", 'integer');
} }
/** /**
* Returns the current id of a sequence * Returns the current id of a sequence
@ -83,7 +83,7 @@ class Doctrine_Sequence_Pgsql extends Doctrine_Sequence
*/ */
public function currId($seqName) public function currId($seqName)
{ {
$sequenceName = $this->quoteIdentifier($this->getSequenceName($seqName), true); $sequenceName = $this->conn->quoteIdentifier($this->conn->getSequenceName($seqName), true);
return $this->fetchOne('SELECT last_value FROM ' . $sequenceName, 'integer'); return (int) $this->conn->fetchOne('SELECT last_value FROM ' . $sequenceName);
} }
} }