You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
77 lines
2.5 KiB
77 lines
2.5 KiB
<?php
|
|
|
|
/**
|
|
*
|
|
*/
|
|
class MigrationMSSQL extends Migration {
|
|
|
|
public function __construct($dbhost, $dbport = '1433', $dbuser, $dbpass, $dbname, $boost=false) {
|
|
parent::__construct($dbhost, $dbport, $dbuser, $dbpass, $dbname, $boost);
|
|
ini_set('display_errors', 1);
|
|
ini_set('mssql.datetimeconvert', 0);
|
|
$this->odbtype = 'mssql';
|
|
}
|
|
|
|
public function connect() {
|
|
$this->c = mssql_connect($this->odbhost, $this->odbuser, $this->odbpass, TRUE);
|
|
if ($this->c === false) {
|
|
$this->errors_stack[] = 'Could not connect. MSSQL error: ' . mssql_get_last_message();
|
|
return false;
|
|
}
|
|
mssql_select_db($this->odbname, $this->c);
|
|
return true;
|
|
}
|
|
|
|
public function select_all($table, $fields, $options = array()) {
|
|
$fields_sql = '';
|
|
foreach ($fields as $field) {
|
|
$fields_sql .= $field . ', ';
|
|
}
|
|
if (!empty($fields_sql)) {
|
|
$fields_sql = substr($fields_sql, 0, -2);
|
|
}
|
|
//In order to process X item of each table add TOP X
|
|
|
|
$top = null;
|
|
// $top = " TOP 100000 ";
|
|
if (in_array($table, array('Empleado', 'Alumno'))) {
|
|
//$top = " TOP 2000 ";
|
|
}
|
|
|
|
if ($table == 'ProgramaAcademico') {
|
|
//$top = ' TOP 1000 ';
|
|
}
|
|
if ($table == 'Matricula') {
|
|
//$top = " TOP 1000 ";
|
|
}
|
|
|
|
//$top = null;
|
|
//$top = " TOP 10 " ;
|
|
$extra = null;
|
|
if (isset($options) && !empty($options['inner_join'])) {
|
|
$extra = ' '.$options['alias_orig_table'].' INNER JOIN '.$options['inner_join'].' '.$options['alias_join_table'].' ON '.$options['on'];
|
|
}
|
|
$order = isset($options['order']) ? $options['order'] : null;
|
|
|
|
$sql = "SELECT $top $fields_sql FROM $table $extra $order";
|
|
$sql = isset($options['query']) ? sprintf($options['query'], "$top $fields_sql") : $sql;
|
|
|
|
//Remove
|
|
$this->rows_iterator = mssql_query($sql, $this->c);
|
|
|
|
if ($this->rows_iterator === false) {
|
|
error_log("--- Error with query $sql MSSQL error: ".mssql_get_last_message()."-- \n");
|
|
}
|
|
}
|
|
|
|
public function fetch_row() {
|
|
return mssql_fetch_row($this->rows_iterator);
|
|
}
|
|
|
|
public function fetch_array() {
|
|
return mssql_fetch_array($this->rows_iterator, MSSQL_ASSOC);
|
|
}
|
|
public function num_rows() {
|
|
return mssql_num_rows($this->rows_iterator);
|
|
}
|
|
}
|
|
|