1 files changed, 75 insertions, 0 deletions
diff --git a/framework/db/schema/mssql/CMssqlPdoAdapter.php b/framework/db/schema/mssql/CMssqlPdoAdapter.php
new file mode 100644
index 0000000..aca6343
--- /dev/null
+++ b/framework/db/schema/mssql/CMssqlPdoAdapter.php
@@ -0,0 +1,75 @@
+<?php
+/**
+ * CMssqlPdo class file
+ *
+ * @author Christophe Boulain <Christophe.Boulain@gmail.com>
+ * @link http://www.yiiframework.com/
+ * @copyright Copyright &copy; 2008-2011 Yii Software LLC
+ * @license http://www.yiiframework.com/license/
+ */
+
+/**
+ * This is an extension of default PDO class for mssql driver only
+ * It provides some missing functionalities of pdo driver
+ * @author Christophe Boulain <Christophe.Boulain@gmail.com>
+ * @version $Id: CMssqlPdoAdapter.php 3515 2011-12-28 12:29:24Z mdomba $
+ * @package system.db.schema.mssql
+ */
+class CMssqlPdoAdapter extends PDO
+{
+	/**
+	 * Get the last inserted id value
+	 * MSSQL doesn't support sequence, so, argument is ignored
+	 *
+	 * @param string|null sequence name. Defaults to null
+	 * @return integer last inserted id
+	 */
+	public function lastInsertId ($sequence=NULL)
+	{
+		$value=$this->query('SELECT SCOPE_IDENTITY()')->fetchColumn();
+		$value=preg_replace('/[,.]0+$/', '', $value); // issue 2312
+		return strtr($value,array(','=>'','.'=>''));
+	}
+
+	/**
+	 * Begin a transaction
+	 *
+	 * Is is necessary to override pdo's method, as mssql pdo drivers
+	 * does not support transaction
+	 *
+	 * @return boolean
+	 */
+	public function beginTransaction ()
+	{
+		$this->exec('BEGIN TRANSACTION');
+		return true;
+	}
+
+	/**
+	 * Commit a transaction
+	 *
+	 * Is is necessary to override pdo's method, as mssql pdo drivers
+	 * does not support transaction
+	 *
+	 * @return boolean
+	 */
+	public function commit ()
+	{
+		$this->exec('COMMIT TRANSACTION');
+		return true;
+	}
+
+	/**
+	 * Rollback a transaction
+	 *
+	 * Is is necessary to override pdo's method, ac mssql pdo drivers
+	 * does not support transaction
+	 *
+	 * @return boolean
+	 */
+	public function rollBack ()
+	{
+		$this->exec('ROLLBACK TRANSACTION');
+		return true;
+	}
+}