<?php
/* $Id$ */
namespace Mammut\DB\MSSQL;

(defined('MAMMUT') && (basename(__FILE__) != basename($_SERVER['PHP_SELF']))) or die('ACCESS DENIED');

use Mammut\DB\DB;
use Mammut\DB\Model\TableInfo;

/**
 * Utility class for linked servers
 * 
 * @author Stefan Daurer <s.daurer@q-spot.org>
 * @package Mammut\DB\Adapter\MSSQL
 */
class LinkedSrv extends \Mammut\DB\DB {
	const _VERSION_ = '1.0.1.0';
	
	/**
	 * The base server
	 *
	 * @var DB
	 */
	protected $srv;
	/**
	 * The name of the linked server
	 *
	 * @var string
	 */
	protected $name;
	protected $db;

	private function __construct(MSSQL $srv, $name) {
		$this->srv = $srv;
		$this->name = $this->name;
	}

	public function close() {
		// return $this->db->close();
	}

	public function setDatabase($name) {
		return $this->db = $name;
	}

	public function getDatabase() {
		return $this->db;
	}

	public function isTransactionSupported() {
		return false;
	}

	public function setAutocommit($doAutoCommit) {
		// return $this->db->setAutocommit($doAutoCommit);
	}

	public function startTransaction() {
		// return $this->db->startTransaction();
	}

	public function commit() {
		// return $this->db->commit();
	}

	public function rollback() {
		// return $this->db->rollback();
	}

	public function query($query, $limit = -1, $skip = 0) {
		return $this->db->query($query, $limit, $skip);
	}

	public function prepareStatement($query, $limit = -1, $skip = 0) {
		return $this->db->prepareStatement($query, $limit, $skip);
	}

	public function getObject($query, $class = false, $param = array()) {
		return $this->db->getObject($query, $class, $param);
	}

	public function getArray($query) {
		return $this->db->getArray($query);
	}

	public function getRow($query) {
		return $this->db->getRow($query);
	}

	public function getInsertId() {
		return $this->db->getInsertId();
	}

	public function getAffectedRowCount() {
		return $this->db->getAffectedRowCount();
	}

	public function table($name, $addPrefix = true) {
		return $this->db->table($name, $addPrefix);
	}

	public function tableExists($table, $addPrefix = true) {
		return $this->db->tableExists($table, $addPrefix);
	}

	public function tableList($removePrefix = true) {
		return $this->db->tableList($removePrefix);
	}

	public function createTable(TableInfo $info, $addPrefix = true) {
		return $this->db->createTable($info, $addPrefix);
	}

	public function getTableInfo($tablename, $addPrefix = true) {
		return $this->db->getTableInfo($tablename, $addPrefix);
	}

	public function dropTable($table, $addPrefix = true) {
		return $this->db->dropTable($table, $addPrefix);
	}

	public function dateCol2uts($date) {
		return $this->db->dateCol2uts($date);
	}

	public function uts2dateCol($uts) {
		return $this->db->uts2dateCol($uts);
	}

	public function datetimeCol2uts($datetime) {
		return $this->db->datetimeCol2uts($datetime);
	}

	public function uts2datetimeCol($uts) {
		return $this->db->uts2datetimeCol($uts);
	}

	function escapeString($text) {
		return $this->db->escapeString($text);
	}

	public function escapeTableName($name, $addPrefix = true) {
		return $this->db->escapeTableName($name, $addPrefix);
	}

	public function escapeColumnName($name) {
		return $this->db->escapeColumnName($name);
	}

	public function escapeValue($value) {
		return $this->db->escapeValue($value);
	}

	public function getQueryCount() {
		return $this->db->getQueryCount();
	}

	public function getDialect() {
		return $this->db->getDialect();
	}
}