connection = sqlsrv_connect( $this->server, array( "UID"=>$this->login, "PWD"=>$this->password, "Database"=>$this->database) ); if ( !$this->connection ) { error_log("sqlsrv_connect() failed : please check your connection information"); } } private function disconnectionFromDatabase() { if( $this->connection != null ) sqlsrv_close($this->connection); } private function executeQuery() { $this->result = sqlsrv_query( $this->connection, $this->query ); } private function retrieveNumRows() { $this->executeQuery(); $this->numberOfResults = sqlsrv_num_rows( $this->result ); } public static function queryOnDatabase($query) { $sqlServerManager = new SQLServerManager(); $sqlServerManager->query = $query; $sqlServerManager->connectionToDatabase(); $sqlServerManager->executeQuery(); $sqlServerManager->resultArray = array(); if( $sqlServerManager->result ) { try { while( $row = sqlsrv_fetch_object( $sqlServerManager->result ) ) { array_push( $sqlServerManager->resultArray, $row ); } } catch (exception $e) { return ""; } return $sqlServerManager->resultArray; } else { return $sqlServerManager->resultArray = array(); } } public static function getNumRows($query) { $sqlServerManager = new SQLServerManager(); $sqlServerManager->query = $query; $sqlServerManager->connectionToDatabase(); $sqlServerManager->retrieveNumRows(); return $sqlServerManager->numberOfResults; } public static function getLastId($table, $transaction) { $query = "SELECT id FROM $table WHERE ID = @@Identity;"; $resource = sqlsrv_query( $transaction, $query ); $id = sqlsrv_fetch_object( $resource ); return $id->id; } public static function startTransaction() { $sqlServerManager = new SQLServerManager(); $sqlServerManager->connectionToDatabase(); if( sqlsrv_begin_transaction( $sqlServerManager->connection ) === false ) { return false; } return $sqlServerManager->connection; } public static function executeQueryForTransaction($query, $transaction) { return sqlsrv_query( $transaction, $query ); } public static function commitTransaction($transaction) { sqlsrv_commit( $transaction ); } public static function rollBackTransaction($transaction) { sqlsrv_rollback( $transaction ); } public static function convertStringToSQLServer($string) { return str_replace( "'", "''", utf8_decode( $string ) ); } } ?>