- moodle_database::get_driver_instance('mysqli', 'native'),
'pgsql' => moodle_database::get_driver_instance('pgsql', 'native'),
'oci' => moodle_database::get_driver_instance('oci', 'native'),
- //'sqlsrv' => moodle_database::get_driver_instance('sqlsrv', 'native'), // new MS sql driver - win32 only
+ 'sqlsrv' => moodle_database::get_driver_instance('sqlsrv', 'native'), // Microsoft SQL*Server Native UTF-8 sql driver - win32 only
'mssql' => moodle_database::get_driver_instance('mssql', 'native'), // FreeTDS driver
);
Index: lib/dml/sqlsrv_native_moodle_database.php
=========================================================
--- lib/dml/sqlsrv_native_moodle_database.php (revision 0)
+++ lib/dml/sqlsrv_native_moodle_database.php Wed Jun 23 12:58:37 PDT 2010
@@ -0,0 +1,1342 @@
+.
+
+/**
+* Native sqlsrv class representing moodle database interface.
+*
+* @package moodlecore
+* @subpackage DML
+* @copyright 2009 onwards Eloy Lafuente (stronk7) {@link http://stronk7.com}
+* @license http://www.gnu.org/copyleft/gpl.html GNU GPL v2 or later
+*/
+
+require_once($CFG->libdir.'/dml/moodle_database.php');
+require_once($CFG->libdir.'/dml/sqlsrv_native_moodle_recordset.php');
+require_once($CFG->libdir.'/dml/sqlsrv_native_moodle_temptables.php');
+
+/**
+* Native sqlsrv class representing moodle database interface.
+*/
+class sqlsrv_native_moodle_database extends moodle_database {
+
+ protected $sqlsrv = null;
+ protected $last_error_reporting; // To handle SQL*Server-Native driver default verbosity
+ protected $temptables; // Control existing temptables (sqlsrv_moodle_temptables object)
+
+ /**
+ * Contructor - instantiates the database, specifying if it's external (connect to other systems) or no (Moodle DB)
+ * note this has effect to decide if prefix checks must be performed or no
+ * @param bool true means external database used
+ */
+ public function __construct($external=false) {
+ parent::__construct($external);
+ }
+
+ /**
+ * Setup the driver configuration. As a TODO, might want to put some levele of debugging to
+ * see / log more info, warnings, errors.
+ }
+
+ /**
+ * Detects if all needed PHP stuff installed.
+ * Note: can be used before connect()
+ * @return mixed true if ok, string if something
+ */
+ public function driver_installed() {
+ // use 'function_exists()' rather than 'extension_loaded()' because
+ // the name used by 'extension_loaded()' is case specific! The extention
+ // therefor *could be* mixed case and hence not found.
+ if (!function_exists('sqlsrv_num_rows')) {
+ return get_string('sqlsrvextensionisnotpresentinphp', 'install');
+ }
+ return true;
+ }
+
+ /**
+ * Returns database family type - describes SQL dialect
+ * Note: can be used before connect()
+ * @return string db family name (mysql, postgres, mssql, sqlsrv, oracle, etc.)
+ */
+ public function get_dbfamily() {
+ /**
+ * NOTE: If this is changed to use the mssql family of
+ * databases, then sqlsrv_sql_generator.php can be deleted
+ * because it will not be used.
+ */
+ return 'mssql';
+ }
+
+ /**
+ * Returns more specific database driver type
+ * Note: can be used before connect()
+ * @return string db type mysql, pgsql, postgres7, mssql, sqlsrv
+ */
+ protected function get_dbtype() {
+ return 'sqlsrv';
+ }
+
+ /**
+ * Returns general database library name
+ * Note: can be used before connect()
+ * @return string db type pdo, native
+ */
+ protected function get_dblibrary() {
+ return 'native';
+ }
+
+ /**
+ * Returns localised database type name
+ * Note: can be used before connect()
+ * @return string
+ */
+ public function get_name() {
+ return get_string('nativesqlsrv', 'install');
+ }
+
+ /**
+ * Returns localised database configuration help.
+ * Note: can be used before connect()
+ * @return string
+ */
+ public function get_configuration_help() {
+ return get_string('nativesqlsrvhelp', 'install');
+ }
+
+ /**
+ * Returns localised database description
+ * Note: can be used before connect()
+ * @return string
+ */
+ public function get_configuration_hints() {
+ $str = get_string('databasesettingssub_sqlsrv', 'install');
+ $str .= "
';
+ return $str;
+ }
+
+ /**
+ * Connect to db
+ * Must be called before other methods.
+ * @param string $dbhost
+ * @param string $dbuser
+ * @param string $dbpass
+ * @param string $dbname
+ * @param mixed $prefix string means moodle db prefix, false used for external databases where prefix not used
+ * @param array $dboptions driver specific options
+ * @return bool true
+ * @throws dml_connection_exception if error
+ */
+ public function connect($dbhost, $dbuser, $dbpass, $dbname, $prefix, array $dboptions=null) {
+ $driverstatus = $this->driver_installed();
+
+ if ($driverstatus !== true) {
+ throw new dml_exception('dbdriverproblem', $driverstatus);
+ }
+
+ /*
+ * Log all Errors.
+ */
+ sqlsrv_configure("WarningsReturnAsErrors", FALSE);
+ sqlsrv_configure("LogSubsystems", SQLSRV_LOG_SYSTEM_ALL);
+ sqlsrv_configure("LogSeverity", SQLSRV_LOG_SEVERITY_ERROR);
+
+ $this->store_settings($dbhost, $dbuser, $dbpass, $dbname, $prefix, $dboptions);
+ $this->sqlsrv = sqlsrv_connect($this->dbhost, array
+ (
+ 'UID' => $this->dbuser,
+ 'PWD' => $this->dbpass,
+ 'Database' => $this->dbname,
+ 'CharacterSet' => 'UTF-8',
+ 'MultipleActiveResultSets' => true,
+ 'ConnectionPooling' => $dboptions['dbpersist'],
+ 'ReturnDatesAsStrings' => true,
+ ));
+
+ if ($this->sqlsrv === false) {
+ $this->sqlsrv = null;
+ $dberr = $this->get_last_error();
+
+ throw new dml_connection_exception($dberr);
+ }
+
+ // Allow quoted identifiers
+ $sql = "SET QUOTED_IDENTIFIER ON";
+ $this->query_start($sql, null, SQL_QUERY_AUX);
+ $result = sqlsrv_query($this->sqlsrv, $sql);
+ $this->query_end($result);
+
+ $this->free_result($result);
+
+ // Force ANSI nulls so the NULL check was done by IS NULL and NOT IS NULL
+ // instead of equal(=) and distinct(<>) symbols
+ $sql = "SET ANSI_NULLS ON";
+ $this->query_start($sql, null, SQL_QUERY_AUX);
+ $result = sqlsrv_query($this->sqlsrv, $sql);
+ $this->query_end($result);
+
+ $this->free_result($result);
+
+ // Force ANSI warnings so arithmetic/string overflows will be
+ // returning error instead of transparently truncating data
+ $sql = "SET ANSI_WARNINGS ON";
+ $this->query_start($sql, null, SQL_QUERY_AUX);
+ $result = sqlsrv_query($this->sqlsrv, $sql);
+ $this->query_end($result);
+
+ // Concatenating null with anything MUST return NULL
+ $sql = "SET CONCAT_NULL_YIELDS_NULL ON";
+ $this->query_start($sql, null, SQL_QUERY_AUX);
+ $result = sqlsrv_query($this->sqlsrv, $sql);
+ $this->query_end($result);
+
+ $this->free_result($result);
+
+ // Set transactions isolation level to READ_COMMITTED
+ // prevents dirty reads when using transactions +
+ // is the default isolation level of sqlsrv
+ $sql = "SET TRANSACTION ISOLATION LEVEL READ COMMITTED";
+ $this->query_start($sql, NULL, SQL_QUERY_AUX);
+ $result = sqlsrv_query($this->sqlsrv, $sql);
+ $this->query_end($result);
+
+ $this->free_result($result);
+
+ // Connection established and configured, going to instantiate the temptables controller
+ $this->temptables = new sqlsrv_native_moodle_temptables($this);
+
+ return true;
+ }
+
+ /**
+ * Close database connection and release all resources
+ * and memory (especially circular memory references).
+ * Do NOT use connect() again, create a new instance if needed.
+ */
+ public function dispose() {
+ parent::dispose(); // Call parent dispose to write/close session and other common stuff before closing connection
+
+ if ($this->sqlsrv) {
+ sqlsrv_close($this->sqlsrv);
+ $this->sqlsrv = null;
+ }
+ }
+
+ /**
+ * Called before each db query.
+ * @param string $sql
+ * @param array array of parameters
+ * @param int $type type of query
+ * @param mixed $extrainfo driver specific extra information
+ * @return void
+ */
+ protected function query_start($sql, array $params = null, $type, $extrainfo = null) {
+ parent::query_start($sql, $params, $type, $extrainfo);
+ }
+
+ /**
+ * Called immediately after each db query.
+ * @param mixed db specific result
+ * @return void
+ */
+ protected function query_end($result) {
+ parent::query_end($result);
+ }
+
+ /**
+ * Returns database server info array
+ * @return array
+ */
+ public function get_server_info() {
+ static $info;
+
+ if (!$info) {
+ $server_info = sqlsrv_server_info($this->sqlsrv);
+
+ if ($server_info) {
+ $info['server'] = $server_info['SQLServerName'];
+ $info['version'] = $server_info['SQLServerVersion'];
+ $info['database'] = $server_info['CurrentDatabase'];
+ }
+ }
+ return $info;
+ }
+
+ /**
+ * Get the minimum SQL allowed
+ *
+ * @param mixed $version
+ * @return mixed
+ */
+ protected function is_min_version($version) {
+ $server = $this->get_server_info();
+ $server = $server['version'];
+ return version_compare($server, $version, '>=');
+ }
+
+ /**
+ * Override: Converts short table name {tablename} to real table name
+ * supporting temp tables (#) if detected
+ *
+ * @param string sql
+ * @return string sql
+ */
+ protected function fix_table_names($sql) {
+ if (preg_match_all('/\{([a-z][a-z0-9_]*)\}/i', $sql, $matches)) {
+ foreach ($matches[0] as $key => $match) {
+ $name = $matches[1][$key];
+
+ if ($this->temptables->is_temptable($name)) {
+ $sql = str_replace($match, $this->temptables->get_correct_name($name), $sql);
+ } else {
+ $sql = str_replace($match, $this->prefix.$name, $sql);
+ }
+ }
+ }
+ return $sql;
+ }
+
+ /**
+ * Returns supported query parameter types
+ * @return bitmask
+ */
+ protected function allowed_param_types() {
+ return SQL_PARAMS_QM; // sqlsrv 1.1 can bind
+ }
+
+ /**
+ * Returns last error reported by database engine.
+ */
+ public function get_last_error() {
+ $retErrors = sqlsrv_errors(SQLSRV_ERR_ALL);
+ $errorMessage = 'No errors found';
+
+ if ($retErrors != null) {
+ $errorMessage = '';
+
+ foreach ($retErrors as $arrError) {
+ $errorMessage .= "SQLState: ".$arrError['SQLSTATE']."