| <?php |
| /** |
| * File containing the ezcPersistentSequenceGenerator class |
| * |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| * |
| * @package PersistentObject |
| * @version //autogen// |
| * @license http://www.apache.org/licenses/LICENSE-2.0 Apache License, Version 2.0 |
| */ |
| |
| /** |
| * Generates IDs based on the PDO::lastInsertId method. |
| * |
| * It is recommended to use auto_increment id columns for databases supporting |
| * it. This includes MySQL and SQLite. Use {@link ezcPersistentNativeGenerator} |
| * for those! |
| * |
| * For none auto_increment databases: |
| * <code> |
| * CREATE TABLE test ( id integer unsigned not null, PRIMARY KEY (id )); |
| * CREATE SEQUENCE test_seq START 1; |
| * </code> |
| * |
| * This class reads the parameters: |
| * - sequence - The name of the database sequence keeping track of the ID. This field should be ommited for databases |
| * supporting auto_increment. |
| * |
| * @apichange The usage of this generator for MySQL is deprecated. Use |
| * {@link ezcPersistentNativeGenerator} instead. |
| * @package PersistentObject |
| * @version //autogen// |
| */ |
| class ezcPersistentSequenceGenerator extends ezcPersistentIdentifierGenerator |
| { |
| /** |
| * Native generator, if sequence generator is used with MySQL or SQLite. |
| * |
| * @var ezcPersistentNativeGenerator |
| */ |
| private $nativeGenerator; |
| /** |
| * Fetches the next sequence value for PostgreSQL and Oracle implementations. |
| * Fetches the next sequence value for PostgreSQL and Oracle implementations. |
| * Dispatches to {@link ezcPersistentNativeGenerator} for MySQL. |
| * |
| * @param ezcPersistentObjectDefinition $def |
| * @param ezcDbHandler $db |
| * @param ezcQueryInsert $q |
| * @return void |
| */ |
| public function preSave( ezcPersistentObjectDefinition $def, ezcDbHandler $db, ezcQueryInsert $q ) |
| { |
| // We first had the native generator within here |
| // For BC reasons we still allow to use the seq generator with MySQL. |
| if ( $db->getName() === "mysql" || $db->getName() === "sqlite" ) |
| { |
| if ( $this->nativeGenerator === null ) |
| { |
| $this->nativeGenerator = new ezcPersistentNativeGenerator(); |
| } |
| return $this->nativeGenerator->preSave( $def, $db, $q ); |
| } |
| |
| if ( isset( $def->idProperty->generator->params["sequence"] ) ) |
| { |
| $seq = $def->idProperty->generator->params["sequence"]; |
| $q->set( $db->quoteIdentifier( $def->idProperty->columnName ), "nextval(" . $db->quote( $db->quoteIdentifier( $seq ) ) . ")" ); |
| } |
| } |
| |
| /** |
| * Returns the integer value of the generated identifier for the new object. |
| * Called right after execution of the insert query. |
| * Dispatches to {@link ezcPersistentNativeGenerator} for MySQL. |
| * |
| * @param ezcPersistentObjectDefinition $def |
| * @param ezcDbHandler $db |
| * @return int |
| */ |
| public function postSave( ezcPersistentObjectDefinition $def, ezcDbHandler $db ) |
| { |
| if ( $db->getName() == "mysql" || $db->getName() == "sqlite" ) |
| { |
| $native = new ezcPersistentNativeGenerator(); |
| return $native->postSave( $def, $db ); |
| } |
| $id = null; |
| if ( array_key_exists( 'sequence', $def->idProperty->generator->params ) && |
| $def->idProperty->generator->params['sequence'] !== null ) |
| { |
| switch ( $db->getName() ) |
| { |
| case "oracle": |
| $idRes = $db->query( "SELECT " . $db->quoteIdentifier( $def->idProperty->generator->params['sequence'] ) . ".CURRVAL AS id FROM " . $db->quoteIdentifier( $def->table ) )->fetch(); |
| $id = (int) $idRes["id"]; |
| break; |
| default: |
| $id = (int)$db->lastInsertId( $db->quoteIdentifier( $def->idProperty->generator->params['sequence'] ) ); |
| break; |
| } |
| } |
| else |
| { |
| $id = (int)$db->lastInsertId(); |
| } |
| // check that the value was in fact successfully received. |
| if ( $db->errorCode() != 0 ) |
| { |
| return null; |
| } |
| return $id; |
| } |
| } |
| |
| ?> |