本文整理汇总了PHP中PropelPDO类的典型用法代码示例。如果您正苦于以下问题：PHP PropelPDO类的具体用法？PHP PropelPDO怎么用？PHP PropelPDO使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了PropelPDO类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的PHP代码示例。
示例1: exec
public static function exec($callable, $arrArgs, $action, $creator = null, $related = null, PropelPDO $con)
{
if (!$con->beginTransaction()) {
throw new Exception('Could not begin transaction');
}
try {
$resIsArray = $res = false;
$res = $return = call_user_func_array($callable, $arrArgs);
$resIsArray = is_array($res);
if ($resIsArray) {
if (isset($res[self::ARR_RESULT_RETURN_KEY])) {
$return = $res[self::ARR_RESULT_RETURN_KEY];
unset($res[self::ARR_RESULT_RETURN_KEY]);
}
if (!$related && isset($res[self::ARR_RELATED_RETURN_KEY])) {
$related = $res[self::ARR_RELATED_RETURN_KEY];
unset($res[self::ARR_RELATED_RETURN_KEY]);
}
}
self::insert($action, self::TYPE_SUCCESS, $creator, $related, $resIsArray ? $res : [$res], null, $con);
if (!$con->commit()) {
throw new Exception('Could not commit transaction');
}
return $return;
} catch (Exception $e) {
$con->rollBack();
$activity = self::insert($action, self::TYPE_FAILURE, $creator, $related, $resIsArray ? $res : [$res], $e, $con);
self::$_ActivityExceptions[] = $activity->toArray();
throw $e;
}
}
开发者ID:nikonehauser，项目名称:ptclient，代码行数:31，代码来源:Activity.php
示例2: getAvailableYearsForCourseId
public static function getAvailableYearsForCourseId($courseId, PropelPDO $propelConnection)
{
$query = "SELECT DISTINCT %s as y FROM %s JOIN %s ON %s=%s WHERE %s='%s' ORDER BY y DESC";
$query = sprintf($query, CourseInstructorAssociationPeer::YEAR, AutoCourseRatingPeer::TABLE_NAME, CourseInstructorAssociationPeer::TABLE_NAME, AutoCourseRatingPeer::COURSE_INS_ID, CourseInstructorAssociationPeer::ID, CourseInstructorAssociationPeer::COURSE_ID, $courseId);
$statement = $propelConnection->prepare($query);
$statement->execute();
$resultset = $statement->fetchAll(PDO::FETCH_COLUMN, 0);
return $resultset;
}
开发者ID:jasonkouoft，项目名称:SkuleCourses，代码行数:9，代码来源:AutoCourseRatingPeer.php
示例3: getClassName
protected static function getClassName(PropelPDO $con)
{
// Get the database type
$type = $con->getAttribute(PDO::ATTR_DRIVER_NAME);
$filter = new Zend_Filter_Word_UnderscoreToCamelCase();
$type = $filter->filter($type);
$class = 'Meshing_Database_Locker_' . $type;
return $class;
}
开发者ID:halfer，项目名称:Meshing，代码行数:9，代码来源:Locker.php
示例4: getHistoricalInstructorsForCourseId
public static function getHistoricalInstructorsForCourseId($courseId, PropelPDO $propelConnection)
{
$query = "SELECT DISTINCT CONCAT(%s,', ',%s) AS name, %s FROM %s RIGHT JOIN %s ON %s=%s WHERE %s<>(SELECT MAX(%s) FROM %s WHERE %s='%s') AND %s='%s' ORDER BY name ASC";
$query = sprintf($query, InstructorPeer::LAST_NAME, InstructorPeer::FIRST_NAME, InstructorPeer::ID, InstructorPeer::TABLE_NAME, CourseInstructorAssociationPeer::TABLE_NAME, InstructorPeer::ID, CourseInstructorAssociationPeer::INSTRUCTOR_ID, CourseInstructorAssociationPeer::YEAR, CourseInstructorAssociationPeer::YEAR, CourseInstructorAssociationPeer::TABLE_NAME, CourseInstructorAssociationPeer::COURSE_ID, $courseId, CourseInstructorAssociationPeer::COURSE_ID, $courseId);
$statement = $propelConnection->prepare($query);
$statement->execute();
$resultset = $statement->fetchAll();
return $resultset;
}
开发者ID:jasonkouoft，项目名称:SkuleCourses，代码行数:9，代码来源:CourseInstructorAssociationPeer.php
示例5: getAvailableYearsForCourseId
public static function getAvailableYearsForCourseId($courseId, PropelPDO $propelConnection)
{
$query = "SELECT DISTINCT %s FROM %s WHERE %s='%s' ORDER BY %s DESC";
$query = sprintf($query, ExamPeer::YEAR, ExamPeer::TABLE_NAME, ExamPeer::COURSE_ID, $courseId, ExamPeer::YEAR);
$statement = $propelConnection->prepare($query);
$statement->execute();
$resultset = $statement->fetchAll(PDO::FETCH_COLUMN, 0);
return $resultset;
}
开发者ID:rafd，项目名称:SkuleCourses，代码行数:9，代码来源:ExamPeer.php
示例6: computeDbLength
/**
* Computes the value of the aggregate column length
* Overridden to provide a default of 00:00:00 if the block is empty.
*
* @param PropelPDO $con A connection object
*
* @return mixed The scalar result from the aggregate query
*/
public function computeDbLength(PropelPDO $con)
{
$stmt = $con->prepare('SELECT SUM(cliplength) FROM "cc_blockcontents" WHERE cc_blockcontents.BLOCK_ID = :p1');
$stmt->bindValue(':p1', $this->getDbId());
$stmt->execute();
$length = $stmt->fetchColumn();
if (is_null($length)) {
$length = "00:00:00";
}
return $length;
}
开发者ID:nidzix，项目名称:Airtime，代码行数:19，代码来源:CcBlock.php
示例7: updateAncestorsTree
/**
* Update all ancestor entries to reflect changes on this instance.
*
* @param \PropelPDO $con
*
* @return \Propel\Bundle\PropelAclBundle\Model\Acl\ObjectIdentity $this
*/
protected function updateAncestorsTree(\PropelPDO $con = null)
{
$con->beginTransaction();
$oldAncestors = ObjectIdentityQuery::create()->findAncestors($this, $con);
$children = ObjectIdentityQuery::create()->findGrandChildren($this, $con);
$children->append($this);
if (count($oldAncestors)) {
foreach ($children as $eachChild) {
/*
* Delete only those entries, that are ancestors based on the parent relation.
* Ancestors of grand children up to the current node will be kept.
*/
$query = ObjectIdentityAncestorQuery::create()->filterByObjectIdentityId($eachChild->getId())->filterByObjectIdentityRelatedByAncestorId($oldAncestors, \Criteria::IN);
if ($eachChild->getId() !== $this->getId()) {
$query->filterByAncestorId(array($eachChild->getId(), $this->getId()), \Criteria::NOT_IN);
} else {
$query->filterByAncestorId($this->getId(), \Criteria::NOT_EQUAL);
}
$query->delete($con);
}
}
// This is the new parent object identity!
$parent = $this->getObjectIdentityRelatedByParentObjectIdentityId($con);
if (null !== $parent) {
$newAncestors = ObjectIdentityQuery::create()->findAncestors($parent, $con);
$newAncestors->append($parent);
foreach ($newAncestors as $eachAncestor) {
// This collection contains the current object identity!
foreach ($children as $eachChild) {
$ancestor = ObjectIdentityAncestorQuery::create()->filterByObjectIdentityId($eachChild->getId())->filterByAncestorId($eachAncestor->getId())->findOneOrCreate($con);
// If the entry already exists, next please.
if (!$ancestor->isNew()) {
continue;
}
if ($eachChild->getId() === $this->getId()) {
// Do not save() here, as it would result in an infinite recursion loop!
$this->addObjectIdentityAncestorRelatedByObjectIdentityId($ancestor);
} else {
// Save the new ancestor to avoid integrity constraint violation.
$ancestor->save($con);
$eachChild->addObjectIdentityAncestorRelatedByObjectIdentityId($ancestor)->save($con);
}
}
}
}
$con->commit();
return $this;
}
开发者ID:propelorm，项目名称:PropelAclBundle，代码行数:55，代码来源:ObjectIdentity.php
示例8: doBackupRecord
public static function doBackupRecord(\Criteria $criteria, PropelPDO $con)
{
$db = Propel::getDB($criteria->getDbName());
$dbMap = Propel::getDatabaseMap($criteria->getDbName());
$keys = $criteria->keys();
if (!empty($keys)) {
$tableName = $criteria->getTableName($keys[0]);
} else {
throw new PropelException("Database insert attempted without anything specified to insert");
}
$tableMap = $dbMap->getTable($tableName);
$whereClause = array();
$peer = $tableMap->getPeerClassname();
$versionTable = $peer::$workspaceBehaviorVersionName;
$originTable = $tableMap->getName();
$tables = $criteria->getTablesColumns();
if (empty($tables)) {
throw new \PropelException("Empty Criteria");
}
$fields = array_keys($tableMap->getColumns());
$fields = implode(', ', $fields);
foreach ($tables as $tableName => $columns) {
$whereClause = array();
$params = array();
$stmt = null;
try {
foreach ($columns as $colName) {
$sb = "";
$criteria->getCriterion($colName)->appendPsTo($sb, $params);
$whereClause[] = $sb;
}
$sql = sprintf("INSERT INTO %s (%s) SELECT %s FROM %s WHERE %s", $versionTable, $fields, $fields, $originTable, implode(" AND ", $whereClause));
$stmt = $con->prepare($sql);
$db->bindValues($stmt, $params, $dbMap);
$stmt->execute();
$stmt->closeCursor();
} catch (Exception $e) {
Propel::log($e->getMessage(), Propel::LOG_ERR);
throw new PropelException(sprintf('Unable to execute INSERT INTO statement [%s]', $sql), $e);
}
}
// for each table
}
开发者ID:marcj，项目名称:propel-workspace-behavior，代码行数:43，代码来源:WorkspaceBehaviorPeer.php
示例9: build
public function build($dsn = null, $user = null, $pass = null, $adapter = null)
{
if (null === $dsn) {
$dsn = 'sqlite::memory:';
}
if (null === $adapter) {
$adapter = new DBSQLite();
}
$con = new PropelPDO($dsn, $user, $pass);
$con->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_WARNING);
$this->buildSQL($con);
$this->buildClasses();
$name = $this->getDatabase()->getName();
if (!Propel::isInit()) {
Propel::setConfiguration(array());
}
Propel::setDB($name, $adapter);
Propel::setConnection($name, $con, Propel::CONNECTION_READ);
Propel::setConnection($name, $con, Propel::CONNECTION_WRITE);
return $con;
}
开发者ID:halfer，项目名称:Meshing，代码行数:21，代码来源:PropelQuickBuilder.php
示例10: getAvailableInstructorsForCourseIdAndYear
public static function getAvailableInstructorsForCourseIdAndYear($courseId, $year, PropelPDO $conn)
{
$query = "SELECT DISTINCT %s as i FROM %s JOIN %s ON %s=%s WHERE %s='%s' AND %s=%s";
$query = sprintf($query, CourseInstructorAssociationPeer::ID, AutoCourseRatingPeer::TABLE_NAME, CourseInstructorAssociationPeer::TABLE_NAME, AutoCourseRatingPeer::COURSE_INS_ID, CourseInstructorAssociationPeer::ID, CourseInstructorAssociationPeer::COURSE_ID, $courseId, CourseInstructorAssociationPeer::YEAR, $year);
$statement = $conn->prepare($query);
$statement->execute();
$ids = $statement->fetchAll(PDO::FETCH_COLUMN, 0);
$results = array();
$c = new Criteria();
$c->addJoin(CourseInstructorAssociationPeer::INSTRUCTOR_ID, InstructorPeer::ID);
foreach ($ids as $id) {
$crit = $c->getNewCriterion(CourseInstructorAssociationPeer::ID, $id);
$c->addOr($crit);
}
$c->addAscendingOrderByColumn(InstructorPeer::LAST_NAME);
$c->addAscendingOrderByColumn(InstructorPeer::FIRST_NAME);
$raw = CourseInstructorAssociationPeer::doSelectJoinInstructor($c, $conn);
foreach ($raw as $obj) {
$results[] = $obj->getInstructor();
}
return $results;
}
开发者ID:rafd，项目名称:SkuleCourses，代码行数:22，代码来源:AutoCourseRatingPeer.php
示例11: doSave
protected function doSave(PropelPDO $con)
{
try {
$con->beginTransaction();
if ($this->countCourseSubjectStudentMarks() == 0) {
for ($i = 1; $i <= $this->getCourseSubject()->getCareerSubjectSchoolYear()->getConfiguration()->getCourseMarks(); $i++) {
$course_subject_student_mark = new CourseSubjectStudentMark();
$course_subject_student_mark->setCourseSubjectStudent($this);
$course_subject_student_mark->setMarkNumber($i);
$last_period_close = $this->getCourseSubject()->getCourse()->getCurrentPeriod() - 1;
if ($i <= $last_period_close) {
$course_subject_student_mark->setIsClosed(true);
// se pone la nota como cerrada
}
$course_subject_student_mark->save($con);
}
}
parent::doSave($con);
$con->commit();
} catch (PropelException $e) {
$con->rollBack();
}
}
开发者ID:nvidela，项目名称:kimkelen，代码行数:23，代码来源:CourseSubjectStudent.php
示例12: computeDbLength
/**
* Computes the value of the aggregate column length
* Overridden to provide a default of 00:00:00 if the block is empty.
*
* @param PropelPDO $con A connection object
*
* @return mixed The scalar result from the aggregate query
*/
public function computeDbLength(PropelPDO $con)
{
$sql = <<<SQL
SELECT SUM(cliplength) FROM cc_blockcontents as bc
JOIN cc_files as f ON bc.file_id = f.id
WHERE BLOCK_ID = :b1
AND f.file_exists = true
SQL;
$stmt = $con->prepare($sql);
$stmt->bindValue(':b1', $this->getDbId());
$stmt->execute();
$length = $stmt->fetchColumn();
if (is_null($length)) {
$length = "00:00:00";
}
return $length;
}
开发者ID:RadioCampusFrance，项目名称:airtime，代码行数:25，代码来源:CcBlock.php
示例13: computeDbLength
/**
* Computes the value of the aggregate column length
* Overridden to provide a default of 00:00:00 if the playlist is empty.
*
* @param PropelPDO $con A connection object
*
* @return mixed The scalar result from the aggregate query
*/
public function computeDbLength(PropelPDO $con)
{
$sql = <<<SQL
SELECT SUM(cliplength) FROM cc_playlistcontents as pc
LEFT JOIN cc_files as f ON pc.file_id = f.id
WHERE PLAYLIST_ID = :p1
AND (f.file_exists is NUll or f.file_exists = true)
SQL;
$stmt = $con->prepare($sql);
$stmt->bindValue(':p1', $this->getDbId());
$stmt->execute();
$length = $stmt->fetchColumn();
if (is_null($length)) {
$length = "00:00:00";
}
return $length;
}
开发者ID:RadioCampusFrance，项目名称:airtime，代码行数:25，代码来源:CcPlaylist.php
示例14: findPkSimple
/**
* Find object by primary key using raw SQL to go fast.
* Bypass doSelect() and the object formatter by using generated code.
*
* @param mixed $key Primary key to use for the query
* @param PropelPDO $con A connection object
*
* @return OrganizationProduct A model object, or null if the key is not found
* @throws PropelException
*/
protected function findPkSimple($key, $con)
{
$sql = 'SELECT `organization_id`, `product_id`, `expires` FROM `organization_product` WHERE `organization_id` = :p0 AND `product_id` = :p1';
try {
$stmt = $con->prepare($sql);
$stmt->bindValue(':p0', $key[0], PDO::PARAM_STR);
$stmt->bindValue(':p1', $key[1], PDO::PARAM_INT);
$stmt->execute();
} catch (Exception $e) {
Propel::log($e->getMessage(), Propel::LOG_ERR);
throw new PropelException(sprintf('Unable to execute SELECT statement [%s]', $sql), $e);
}
$obj = null;
if ($row = $stmt->fetch(PDO::FETCH_NUM)) {
$obj = new OrganizationProduct();
$obj->hydrate($row);
OrganizationProductPeer::addInstanceToPool($obj, serialize(array((string) $key[0], (string) $key[1])));
}
$stmt->closeCursor();
return $obj;
}
开发者ID:Halfnhav4，项目名称:datawrapper，代码行数:31，代码来源:BaseOrganizationProductQuery.php
示例15: doInsert
/**
* Insert the row in the database.
*
* @param PropelPDO $con
*
* @throws PropelException
* @see doSave()
*/
protected function doInsert(PropelPDO $con)
{
$modifiedColumns = array();
$index = 0;
$this->modifiedColumns[] = CountryPeer::ID;
if (null !== $this->id) {
throw new PropelException('Cannot insert a value for auto-increment primary key (' . CountryPeer::ID . ')');
}
// check the columns in natural order for more readable SQL queries
if ($this->isColumnModified(CountryPeer::ID)) {
$modifiedColumns[':p' . $index++] = '`ID`';
}
if ($this->isColumnModified(CountryPeer::NAME)) {
$modifiedColumns[':p' . $index++] = '`NAME`';
}
if ($this->isColumnModified(CountryPeer::ISO_CODE)) {
$modifiedColumns[':p' . $index++] = '`ISO_CODE`';
}
if ($this->isColumnModified(CountryPeer::ISO_SHORT_CODE)) {
$modifiedColumns[':p' . $index++] = '`ISO_SHORT_CODE`';
}
if ($this->isColumnModified(CountryPeer::DEMONYM)) {
$modifiedColumns[':p' . $index++] = '`DEMONYM`';
}
if ($this->isColumnModified(CountryPeer::DEFAULT_CURRENCY_ID)) {
$modifiedColumns[':p' . $index++] = '`DEFAULT_CURRENCY_ID`';
}
$sql = sprintf('INSERT INTO `country` (%s) VALUES (%s)', implode(', ', $modifiedColumns), implode(', ', array_keys($modifiedColumns)));
try {
$stmt = $con->prepare($sql);
foreach ($modifiedColumns as $identifier => $columnName) {
switch ($columnName) {
case '`ID`':
$stmt->bindValue($identifier, $this->id, PDO::PARAM_INT);
break;
case '`NAME`':
$stmt->bindValue($identifier, $this->name, PDO::PARAM_STR);
break;
case '`ISO_CODE`':
$stmt->bindValue($identifier, $this->iso_code, PDO::PARAM_STR);
break;
case '`ISO_SHORT_CODE`':
$stmt->bindValue($identifier, $this->iso_short_code, PDO::PARAM_STR);
break;
case '`DEMONYM`':
$stmt->bindValue($identifier, $this->demonym, PDO::PARAM_STR);
break;
case '`DEFAULT_CURRENCY_ID`':
$stmt->bindValue($identifier, $this->default_currency_id, PDO::PARAM_INT);
break;
}
}
$stmt->execute();
} catch (Exception $e) {
Propel::log($e->getMessage(), Propel::LOG_ERR);
throw new PropelException(sprintf('Unable to execute INSERT statement [%s]', $sql), $e);
}
try {
$pk = $con->lastInsertId();
} catch (Exception $e) {
throw new PropelException('Unable to get autoincrement id.', $e);
}
$this->setId($pk);
$this->setNew(false);
}
开发者ID:homer6，项目名称:blank_altumo，代码行数:73，代码来源:BaseCountry.php
示例16: doInsert
/**
* Insert the row in the database.
*
* @param PropelPDO $con
*
* @throws PropelException
* @see doSave()
*/
protected function doInsert(PropelPDO $con)
{
$modifiedColumns = array();
$index = 0;
$this->modifiedColumns[] = ExpedientehistorialPeer::IDEXPEDIENTEHISTORIAL;
if (null !== $this->idexpedientehistorial) {
throw new PropelException('Cannot insert a value for auto-increment primary key (' . ExpedientehistorialPeer::IDEXPEDIENTEHISTORIAL . ')');
}
// check the columns in natural order for more readable SQL queries
if ($this->isColumnModified(ExpedientehistorialPeer::IDEXPEDIENTEHISTORIAL)) {
$modifiedColumns[':p' . $index++] = '`idexpedientehistorial`';
}
if ($this->isColumnModified(ExpedientehistorialPeer::IDEXPEDIENTESERVICIO)) {
$modifiedColumns[':p' . $index++] = '`idexpedienteservicio`';
}
if ($this->isColumnModified(ExpedientehistorialPeer::IDESTADOSERVICIO)) {
$modifiedColumns[':p' . $index++] = '`idestadoservicio`';
}
if ($this->isColumnModified(ExpedientehistorialPeer::EXPEDIENTEHISTORIAL_FECHA)) {
$modifiedColumns[':p' . $index++] = '`expedientehistorial_fecha`';
}
if ($this->isColumnModified(ExpedientehistorialPeer::EXPEDIENTEHISTORIAL_NOTA)) {
$modifiedColumns[':p' . $index++] = '`expedientehistorial_nota`';
}
$sql = sprintf('INSERT INTO `expedientehistorial` (%s) VALUES (%s)', implode(', ', $modifiedColumns), implode(', ', array_keys($modifiedColumns)));
try {
$stmt = $con->prepare($sql);
foreach ($modifiedColumns as $identifier => $columnName) {
switch ($columnName) {
case '`idexpedientehistorial`':
$stmt->bindValue($identifier, $this->idexpedientehistorial, PDO::PARAM_INT);
break;
case '`idexpedienteservicio`':
$stmt->bindValue($identifier, $this->idexpedienteservicio, PDO::PARAM_INT);
break;
case '`idestadoservicio`':
$stmt->bindValue($identifier, $this->idestadoservicio, PDO::PARAM_INT);
break;
case '`expedientehistorial_fecha`':
$stmt->bindValue($identifier, $this->expedientehistorial_fecha, PDO::PARAM_STR);
break;
case '`expedientehistorial_nota`':
$stmt->bindValue($identifier, $this->expedientehistorial_nota, PDO::PARAM_STR);
break;
}
}
$stmt->execute();
} catch (Exception $e) {
Propel::log($e->getMessage(), Propel::LOG_ERR);
throw new PropelException(sprintf('Unable to execute INSERT statement [%s]', $sql), $e);
}
try {
$pk = $con->lastInsertId();
} catch (Exception $e) {
throw new PropelException('Unable to get autoincrement id.', $e);
}
$this->setIdexpedientehistorial($pk);
$this->setNew(false);
}
开发者ID:vicbaporu，项目名称:ITRADE，代码行数:67，代码来源:BaseExpedientehistorial.php
示例17: doInsert
/**
* Insert the row in the database.
*
* @param PropelPDO $con
*
* @throws PropelException
* @see doSave()
*/
protected function doInsert(PropelPDO $con)
{
$modifiedColumns = array();
$index = 0;
$this->modifiedColumns[] = DetailBarangMasukPeer::ID;
if (null !== $this->id) {
throw new PropelException('Cannot insert a value for auto-increment primary key (' . DetailBarangMasukPeer::ID . ')');
}
// check the columns in natural order for more readable SQL queries
if ($this->isColumnModified(DetailBarangMasukPeer::ID)) {
$modifiedColumns[':p' . $index++] = '`id`';
}
if ($this->isColumnModified(DetailBarangMasukPeer::ID_BARANG_MASUK)) {
$modifiedColumns[':p' . $index++] = '`id_barang_masuk`';
}
if ($this->isColumnModified(DetailBarangMasukPeer::ID_BARANG)) {
$modifiedColumns[':p' . $index++] = '`id_barang`';
}
if ($this->isColumnModified(DetailBarangMasukPeer::HARGA)) {
$modifiedColumns[':p' . $index++] = '`harga`';
}
$sql = sprintf('INSERT INTO `detail_barang_masuk` (%s) VALUES (%s)', implode(', ', $modifiedColumns), implode(', ', array_keys($modifiedColumns)));
try {
$stmt = $con->prepare($sql);
foreach ($modifiedColumns as $identifier => $columnName) {
switch ($columnName) {
case '`id`':
$stmt->bindValue($identifier, $this->id, PDO::PARAM_INT);
break;
case '`id_barang_masuk`':
$stmt->bindValue($identifier, $this->id_barang_masuk, PDO::PARAM_INT);
break;
case '`id_barang`':
$stmt->bindValue($identifier, $this->id_barang, PDO::PARAM_INT);
break;
case '`harga`':
$stmt->bindValue($identifier, $this->harga, PDO::PARAM_INT);
break;
}
}
$stmt->execute();
} catch (Exception $e) {
Propel::log($e->getMessage(), Propel::LOG_ERR);
throw new PropelException(sprintf('Unable to execute INSERT statement [%s]', $sql), $e);
}
try {
$pk = $con->lastInsertId();
} catch (Exception $e) {
throw new PropelException('Unable to get autoincrement id.', $e);
}
$this->setId($pk);
$this->setNew(false);
}
开发者ID:nurhidayatullah，项目名称:inventory，代码行数:61，代码来源:BaseDetailBarangMasuk.php
示例18: doInsert
/**
* Insert the row in the database.
*
* @param PropelPDO $con
*
* @throws PropelException
* @see doSave()
*/
protected function doInsert(PropelPDO $con)
{
$modifiedColumns = array();
$index = 0;
$this->modifiedColumns[] = afWidgetHelpSettingsPeer::ID;
if (null !== $this->id) {
throw new PropelException('Cannot insert a value for auto-increment primary key (' . afWidgetHelpSettingsPeer::ID . ')');
}
// check the columns in natural order for more readable SQL queries
if ($this->isColumnModified(afWidgetHelpSettingsPeer::ID)) {
$modifiedColumns[':p' . $index++] = '`ID`';
}
if ($this->isColumnModified(afWidgetHelpSettingsPeer::USER_ID)) {
$modifiedColumns[':p' . $index++] = '`USER_ID`';
}
if ($this->isColumnModified(afWidgetHelpSettingsPeer::WIDGET_HELP_IS_ENABLED)) {
$modifiedColumns[':p' . $index++] = '`WIDGET_HELP_IS_ENABLED`';
}
if ($this->isColumnModified(afWidgetHelpSettingsPeer::POPUP_HELP_IS_ENABLED)) {
$modifiedColumns[':p' . $index++] = '`POPUP_HELP_IS_ENABLED`';
}
if ($this->isColumnModified(afWidgetHelpSettingsPeer::HELP_TYPE)) {
$modifiedColumns[':p' . $index++] = '`HELP_TYPE`';
}
if ($this->isColumnModified(afWidgetHelpSettingsPeer::CREATED_AT)) {
$modifiedColumns[':p' . $index++] = '`CREATED_AT`';
}
if ($this->isColumnModified(afWidgetHelpSettingsPeer::UPDATED_AT)) {
$modifiedColumns[':p' . $index++] = '`UPDATED_AT`';
}
$sql = sprintf('INSERT INTO `af_widget_help_settings` (%s) VALUES (%s)', implode(', ', $modifiedColumns), implode(', ', array_keys($modifiedColumns)));
try {
$stmt = $con->prepare($sql);
foreach ($modifiedColumns as $identifier => $columnName) {
switch ($columnName) {
case '`ID`':
$stmt->bindValue($identifier, $this->id, PDO::PARAM_INT);
break;
case '`USER_ID`':
$stmt->bindValue($identifier, $this->user_id, PDO::PARAM_INT);
break;
case '`WIDGET_HELP_IS_ENABLED`':
$stmt->bindValue($identifier, (int) $this->widget_help_is_enabled, PDO::PARAM_INT);
break;
case '`POPUP_HELP_IS_ENABLED`':
$stmt->bindValue($identifier, (int) $this->popup_help_is_enabled, PDO::PARAM_INT);
break;
case '`HELP_TYPE`':
$stmt->bindValue($identifier, $this->help_type, PDO::PARAM_INT);
break;
case '`CREATED_AT`':
$stmt->bindValue($identifier, $this->created_at, PDO::PARAM_STR);
break;
case '`UPDATED_AT`':
$stmt->bindValue($identifier, $this->updated_at, PDO::PARAM_STR);
break;
}
}
$stmt->execute();
} catch (Exception $e) {
Propel::log($e->getMessage(), Propel::LOG_ERR);
throw new PropelException(sprintf('Unable to execute INSERT statement [%s]', $sql), $e);
}
try {
$pk = $con->lastInsertId();
} catch (Exception $e) {
throw new PropelException('Unable to get autoincrement id.', $e);
}
$this->setId($pk);
$this->setNew(false);
}
开发者ID:cbsistem，项目名称:appflower_engine，代码行数:79，代码来源:BaseafWidgetHelpSettings.php
示例19: doInsert
/**
* Insert the row in the database.
*
* @param PropelPDO $con
*
* @throws PropelException
* @see doSave()
*/
protected function doInsert(PropelPDO $con)
{
$modifiedColumns = array();
$index = 0;
// check the columns in natural order for more readable SQL queries
if ($this->isColumnModified(AidDetailsPeer::ID)) {
$modifiedColumns[':p' . $index++] = 'ID';
}
if ($this->isColumnModified(AidDetailsPeer::NOM)) {
$modifiedColumns[':p' . $index++] = 'NOM';
}
if ($this->isColumnModified(AidDetailsPeer::NUMERO)) {
$modifiedColumns[':p' . $index++] = 'NUMERO';
}
if ($this->isColumnModified(AidDetailsPeer::INDICE_AID)) {
$modifiedColumns[':p' . $index++] = 'INDICE_AID';
}
if ($this->isColumnModified(AidDetailsPeer::PERSO1)) {
$modifiedColumns[':p' . $index++] = 'PERSO1';
}
if ($this->isColumnModified(AidDetailsPeer::PERSO2)) {
$modifiedColumns[':p' . $index++] = 'PERSO2';
}
if ($this->isColumnModified(AidDetailsPeer::PERSO3)) {
$modifiedColumns[':p' . $index++] = 'PERSO3';
}
if ($this->isColumnModified(AidDetailsPeer::PRODUCTIONS)) {
$modifiedColumns[':p' . $index++] = 'PRODUCTIONS';
}
if ($this->isColumnModified(AidDetailsPeer::RESUME)) {
$modifiedColumns[':p' . $index++] = 'RESUME';
}
if ($this->isColumnModified(AidDetailsPeer::FAMILLE)) {
$modifiedColumns[':p' . $index++] = 'FAMILLE';
}
if ($this->isColumnModified(AidDetailsPeer::MOTS_CLES)) {
$modifiedColumns[':p' . $index++] = 'MOTS_CLES';
}
if ($this->isColumnModified(AidDetailsPeer::ADRESSE1)) {
$modifiedColumns[':p' . $index++] = 'ADRESSE1';
}
if ($this->isColumnModified(AidDetailsPeer::ADRESSE2)) {
$modifiedColumns[':p' . $index++] = 'ADRESSE2';
}
if ($this->isColumnModified(AidDetailsPeer::PUBLIC_DESTINATAIRE)) {
$modifiedColumns[':p' . $index++] = 'PUBLIC_DESTINATAIRE';
}
if ($this->isColumnModified(AidDetailsPeer::CONTACTS)) {
$modifiedColumns[':p' . $index++] = 'CONTACTS';
}
if ($this->isColumnModified(AidDetailsPeer::DIVERS)) {
$modifiedColumns[':p' . $index++] = 'DIVERS';
}
if ($this->isColumnModified(AidDetailsPeer::MATIERE1)) {
$modifiedColumns[':p' . $index++] = 'MATIERE1';
}
if ($this->isColumnModified(AidDetailsPeer::MATIERE2)) {
$modifiedColumns[':p' . $index++] = 'MATIERE2';
}
if ($this->isColumnModified(AidDetailsPeer::ELEVE_PEUT_MODIFIER)) {
$modifiedColumns[':p' . $index++] = 'ELEVE_PEUT_MODIFIER';
}
if ($this->isColumnModified(AidDetailsPeer::PROF_PEUT_MODIFIER)) {
$modifiedColumns[':p' . $index++] = 'PROF_PEUT_MODIFIER';
}
if ($this->isColumnModified(AidDetailsPeer::CPE_PEUT_MODIFIER)) {
$modifiedColumns[':p' . $index++] = 'CPE_PEUT_MODIFIER';
}
if ($this->isColumnModified(AidDetailsPeer::FICHE_PUBLIQUE)) {
$modifiedColumns[':p' . $index++] = 'FICHE_PUBLIQUE';
}
if ($this->isColumnModified(AidDetailsPeer::AFFICHE_ADRESSE1)) {
$modifiedColumns[':p' . $index++] = 'AFFICHE_ADRESSE1';
}
if ($this->isColumnModified(AidDetailsPeer::EN_CONSTRUCTION)) {
$modifiedColumns[':p' . $index++] = 'EN_CONSTRUCTION';
}
$sql = sprintf(
'INSERT INTO aid (%s) VALUES (%s)',
implode(', ', $modifiedColumns),
implode(', ', array_keys($modifiedColumns))
);
try {
$stmt = $con->prepare($sql);
foreach ($modifiedColumns as $identifier => $columnName) {
switch ($columnName) {
case 'ID':
$stmt->bindValue($identifier, $this->id, PDO::PARAM_STR);
//.........这里部分代码省略.........
开发者ID:rhertzog，项目名称:lcs，代码行数:101，代码来源:BaseAidDetails.php
示例20: doInsert
/**
* Insert the row in the database.
*
* @param PropelPDO $con
*
* @throws PropelException
* @see doSave()
*/
protected function doInsert(PropelPDO $con)
{
$modifiedColumns = array();
$index = 0;
$this->modifiedColumns[] = VentaPeer::IDVENTA;
if (null !== $this->idventa) {
throw new PropelException('Cannot insert a value for auto-increment primary key (' . VentaPeer::IDVENTA . ')');
}
// check the columns in natural order for more readable SQL queries
if ($this->isColumnModified(VentaPeer::IDVENTA)) {
$modifiedColumns[':p' . $index++] = '`IDVENTA`';
}
if ($this->isColumnModified(VentaPeer::FECHA)) {
$modifiedColumns[':p' . $index++] = '`FECHA`';
}
if ($this->isColumnModified(VentaPeer::IDCLIENTE)) {
$modifiedColumns[':p' . $index++] = '`IDCLIENTE`';
}
if ($this->isColumnModified(VentaPeer::IDPRODUCTO)) {
$modifiedColumns[':p' . $index++] = '`IDPRODUCTO`';
}
$sql = sprintf('INSERT INTO `venta` (%s) VALUES (%s)', implode(', ', $modifiedColumns), implode(', ', array_keys($modifiedColumns)));
try {
$stmt = $con->prepare($sql);
foreach ($modifiedColumns as $identifier => $columnName) {
switch ($columnName) {
case '`IDVENTA`':
$stmt->bindValue($identifier, $this->idventa, PDO::PARAM_INT);
break;
case '`FECHA`':
$stmt->bindValue($identifier, $this->fecha, PDO::PARAM_STR);
break;
case '`IDCLIENTE`':
$stmt->bindValue($identifier, $this->idcliente, PDO::PARAM_INT);
break;
case '`IDPRODUCTO`':
$stmt->bindValue($identifier, $this->idproducto, PDO::PARAM_INT);
break;
}
}
$stmt->execute();
} catch (Exception $e) {
Propel::log($e->getMessage(), Propel::LOG_ERR);
throw new PropelException(sprintf('Unable to execute INSERT statement [%s]', $sql), $e);
}
try {
$pk = $con->lastInsertId();
} catch (Exception $e) {
throw new PropelException('Unable to get autoincrement id.', $e);
}
$this->setIdventa($pk);
$this->setNew(false);
}
开发者ID:nestorfsandoval，项目名称:2012_pw2_tp2，代码行数:61，代码来源:BaseVenta.php
注：本文中的PropelPDO类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论