#c# #cloud #css #docker #git #javascript #linux #php #python #sql

PHP - Conectar con SQL Server utilizando clase singleton CBaseDatos

Clase que conecta con sqlserver y mysql. En esta versión singleton he ampliado algunas funcionalidades, como por ejemplo la posibilidad de conectarse a sqlserver y permitir utilizar los metodos query($sSQL) y execute($sSQL) sin que exista la necesidad de instanciar previamente el método conectar(). Una leve mejora en la captura de excepciones. Ahora no se imprimirá todo el objeto "e", solamente el mensaje asociado. El constructor espera argumentos con valores si estos están vacios entonces intentará recuperar el contenido de las constantes.

Descarga la clase CBaseDatos aqui.

CBaseDatos ahora cuenta ahora con:

el método get_rows_affected()

Mostrará la cantidad de registros que han intervenido en la consulta.

el método is_error()

Indica si ha ocurrido un error tanto al leer como al escribir.

El método "get", get_link_id()

Queda obsoleto, de momento está como privado antes era necesario utilizarlo ya que por un lado se creaba un objeto conexión y por otro el componente para atacar la base de datos.

el método convert_to_utf8($arRow=array(), $origCollation="windows-1252")

Es necesario si se va a trabajar con SQLSERVER y el html se presentará en UTF-8. ya que por defecto la codificación con la que trabaja es "windows-1252", vamos la de los sistemas windows

el método convert_to_windows()

El inverso del método anterior. Si deseamos guardar datos desde una página html en utf8 habrá que pasarlos a formato windows.

Definición clase CBaseDatos


<?php
/**
* @author Eduardo Acevedo Farje
* @version 1.2.0
* @web http://www.eduardoaf.com/blog-programacion/programacion-php/php-conectar-con-sql-server-utilizando-clase-singleton-cbasedatos/
* Clase tipo SINGLETON para interactuar con bases de datos sqlserver y mysql
*/
class CBaseDatos 
{
    private $_sServidor;
    private $_sNombreBD;
    private $_sUsuario;
    private $_sClave;
    private $_sTipoBD;
   
    private $_oLinkId;
    private $_sMensaje;
    private $_isError;
    private $_iRowsAffected;
   
    /**
    * @var CBaseDatos
    */
    private static $_oSelf = null;
   
    private function __construct($sServidorBD="",$sNombreBD="",$sUserBD="",$sClaveBD="",$sTipoBD="")
    {
        $this->_sServidor = $sServidorBD;
        $this->_sNombreBD = $sNombreBD;
        $this->_sUsuario = $sUserBD;
        $this->_sClave = $sClaveBD;
        $this->_sTipoBD = $sTipoBD;
        //Se sobreescribe los vacios
        if(empty($sServidorBD))$this->_sServidor = TFW_DB_SERVER;
        if(empty($sNombreBD))$this->_sNombreBD = TFW_DB_NAME;
        if(empty($sUserBD))$this->_sUsuario = TFW_DB_USER;
        if(empty($sClaveBD))$this->_sClave = TFW_DB_PASSWORD;
        if(empty($sTipoBD))$this->_sTipoBD = TFW_DB_TYPE;
        
        //object con Id de Conexión
        $this->_oLinkId = null; 
        $this->_sMensaje = "";
        $this->_isError = false;
    }
   
    /**
    * Este es el pseudo constructor singleton
    * Comprueba si la variable privada $_oSelf tiene un objeto
    * de esta misma clase, sino lo tiene lo crea y lo guarda en dicha variable
    * @return CBaseDatos
    */
    public static function get_instancia($sServidorBD="",$sNombreBD="",$sUserBD="",$sClaveBD="",$sTipo="mysql")
    {
        if(!self::$_oSelf instanceof self)
        {
            self::$_oSelf = new self($sServidorBD,$sNombreBD,$sUserBD,$sClaveBD,$sTipo);
        }
        return self::$_oSelf;
    }

    //=================== CONECTAR ===========================
    private function conectar_mysql()
    {
        $sNombreBD = $this->_sNombreBD;
        if($this->_oLinkId==0 || $this->_oLinkId==null)
        {
            $oConnect = mysql_connect
            (
                $this->_sServidor,
                $this->_sUsuario,
                $this->_sClave
            );
            if(!is_resource($oConnect))
            {
                $this->_sMensaje = "ERROR 0001: No se pudo conectar con la base de datos \"$sNombreBD\"";
                $this->_isError = true;
                return false;
            }
           
            $isExisteBD = mysql_select_db($this->_sNombreBD, $oConnect);
            //si no se pudo encontrar esa BD lanza un error
            if(!$isExisteBD)
            {
                $this->_sMensaje = "ERROR 0002: La base de datos \"$sNombreBD\" ";
                $this->_isError = true;
                return false;
            }
            //Hay base de datos y se conecto
            else
            {
                //Guardo el id de conexión
                $this->_oLinkId = $oConnect;
                $this->_sMensaje = "Conexión realizada con la bd: \"$sNombreBD\"";  
                mysql_set_charset('utf8',$this->_oLinkId);
            }
        }
        //Ya existe recurso abierto, oLinkId!=0
        else
        {}
        return true;
    }
   
    private function conectar_sqlserver()
    {
        $sNombreBD = $this->_sNombreBD;
        if($this->_oLinkId==0 || $this->_oLinkId==null)
        {
            $oConnect = mssql_connect
            (
                $this->_sServidor,
                $this->_sUsuario,
                $this->_sClave
            );
            
            if(!is_resource($oConnect))
            {
                $this->_sMensaje = "ERROR 0003: No se puede conectar a la base de datos..! ".$this->_sNombreBD;
                $this->_isError = true;
                return false;
            }
           
            $isExisteBD  = mssql_select_db($this->_sNombreBD, $oConnect);
            if(!$isExisteBD)
            {
                $this->_sMensaje = "ERROR 0004: La base de datos \"$sNombreBD\" ";
                $this->_isError = true;
                return false;
            }
            //Hay base de datos y se conectó
            else
            {
                $this->_oLinkId = $oConnect;
                $this->_sMensaje = "Conexión realizada con la bd: \"$sNombreBD\"";  
            }
        }
        //Existe recurso abierto
        else
        {}
        return true;
    }
   
    public function conectar()
    {
        $sTipoBD = $this->_sTipoBD;
        $isConnected = false;
        switch ($sTipoBD)
        {
            case "mysql":
                $isConnected = $this->conectar_mysql();
            break;
            case "sqlserver":
                $isConnected = $this->conectar_sqlserver();
            default:
            break;
        }
        return $isConnected;
    }
    //=================== FIN CONECTAR ===========================
    
    //Metodos para utilización de codificación utf8. Sobre todo para entornos windows
    //como SQLServer 2008
    private function convert_to_utf8($arRow=array(), $origCollation="windows-1252")
    {
        $arRowInUtf8 = array();
        foreach ($arRow as $sFieldName => $sValue)
        {
            $arRowInUtf8[$sFieldName] = iconv($origCollation, "utf-8", trim($sValue));
        }
        return $arRowInUtf8;
    }    
    
    private function convert_to_windows($arRow=array(), $origCollation="utf-8")
    {
        $arRowInWindows = array();
        foreach ($arRow as $sFieldName => $sValue)
        {
            $arRowInWindows[$sFieldName] = iconv($origCollation, "windows-1252", $sValue);
        }
        return $arRowInWindows;
    }        
   
    //==================== QUERY==================================
    private function query_mysql($sSQL, $sNombreTabla="table")
    {
        //Cuando se recupera un objeto desde sesion no cuenta
        //con linkid (linkid = 0)
        if(empty($this->_oLinkId)) $this->conectar();
        
        try
        {
            $arTabla = array();
            $arFilas = array();

            $oResource = mysql_query($sSQL, $this->_oLinkId);
            if($oResource!=false)
            {  
                while($arFila = mysql_fetch_array($oResource, MYSQL_ASSOC))
                {
                    $arFilas[] = $arFila;
                }
                if(!empty($sNombreTabla))
                {
                    $arTabla[$sNombreTabla] = $arFilas;
                }
                else
                {
                    $arTabla = $arFilas;
                }
            }
            else
            {
                $this->_isError = true;
                $this->_sMensaje = "ERROR EN SQL: $sSQL";
                return -1;
            }
            return $arTabla;
        }
        catch (Exception $e)
        {
            $this->_isError = true;
            $this->_sMensaje = "ERROR 0005 SQL: $sSQL,\n".$e->getMessage();
            return -1;
        }
    }
    
    private function query_mssql($sSQL, $sNombreTabla="table")
    {
        //Cuando se recupera un objeto desde sesion no cuenta
        //con linkid (linkid = 0)
        if(empty($this->_oLinkId)) $this->conectar();

        $arTabla = array();
        $arFilas = array();
       
        try
        {
            $oResource = mssql_query($sSQL, $this->_oLinkId);
            //oResource existen filas afectadas, true consulta ok pero sin filas
            //false error al ejecutar consulta
            //$oResource=true ó $oResource
            if($oResource!=false)
            {
                while($arFila = mssql_fetch_array($oResource, MSSQL_ASSOC))
                {
                    $arFilas[] = $this->convert_to_utf8($arFila);
                }
                if(!empty($sNombreTabla)) $arTabla[$sNombreTabla] = $arFilas;
                else $arTabla = $arFilas;
                
                $this->_iRowsAffected = mssql_num_rows($oResource);
                mssql_free_result($oResource);
            }
            //$oResource == false //TODO habría que estudiar en que casos se dá
            //esta condición y en que otros se lanza la excepción
            else
            {
                $this->_isError = true;
                $this->_sMensaje = "ERROR EN SQL: $sSQL";
                return -1;
            }            
            return $arTabla;
        }
        catch (Exception $e)
        {
            $this->_isError = true;
            $this->_sMensaje = "ERROR 0006 SQL: $sSQL,\n".$e->getMessage();
            return -1;
        }
    }
    
    public function query($sSQL, $sNombreTabla="")
    {
        $sTipoBD = $this->_sTipoBD;
        $arTabla = array();
        switch ($sTipoBD)
        {
            case "mysql":
                $arTabla = $this->query_mysql($sSQL,$sNombreTabla);
            break;
            case "sqlserver":
                $arTabla = $this->query_mssql($sSQL,$sNombreTabla);
            default:
            break;
        }
        return $arTabla;
    }
    //==================== FIN QUERY ================================
   
    //==================== QUERY OBJECT ================================
    private function query_object_mysql($sSQL)
    {
        try
        {
            $arTabla = array();
            //TODO comprobar lo que devuelve _query
            $oResource = mysql_query($sSQL, $this->_oLinkId);
            while($arFila = mysql_fetch_object($oResource))
            {
                $arTabla[] = $arFila;
            }
            return $arTabla;
        }
        catch (Exception $e)
        {
            $this->_isError = true;
            $this->_sMensaje = "ERROR 0011 SQL: $sSQL,\n".$e->getMessage();
            return -1;
        }
    }
    
    private function query_object_mssql($sSQL)
    {
        try
        {
            $arTabla = array();
            //TODO comprobar lo que devuelve _query
            $oResource = mssql_query($sSQL, $this->_oLinkId);
            
            while($arFila = mssql_fetch_object($oResource))
            {
                $arTabla[] = $arFila;
            }
            $this->_iRowsAffected = mssql_num_rows($oResource);
            mssql_free_result($oResource);            
            return $arTabla;
        }
        catch (Exception $e)
        {
            $this->_isError = true;
            $this->_sMensaje = "ERROR 0012 SQL: $sSQL,\n".$e->getMessage();
            return -1;
        }
    }
    
    public function query_object($sSQL)
    {
        $sTipoBD = $this->_sTipoBD;
        $arTabla = array();
        switch ($sTipoBD)
        {
            case "mysql":
                $arTabla = $this->query_object_mysql($sSQL);
            break;
            case "sqlserver":
                $arTabla = $this->query_object_mssql($sSQL);
            default:
            break;
        }
        return $arTabla;    
    }    
    //==================== FIN QUERY OBJECT ================================

    //==================== EXECUTE ================================
    private function execute_mysql($sSQL)
    {
        //Cuando se recupera un objeto desde sesion no cuenta
        //con linkid (linkid = 0)
        $oLinkId = $this->_oLinkId;
        if(empty($oLinkId))
            $this->conectar();

        try
        {
            $oResource = mysql_query($sSQL);
            if(!$oResource)
            {
                $sMensaje  = "Sentencia SQL con errores: ".mysql_error();
                $sMensaje .= "\nSQL = $sSQL";
                $this->_isError = true;
                $this->_sMensaje = $sMensaje;
                return -1;
            }
        }
        catch(Exception $e)
        {
            $sMensaje  = "Excepción: ".$e->getMessage();
            $sMensaje .= "\nSQL = $sSQL";
            $this->_isError = true;
            $this->_sMensaje = $sMensaje;
            return -1;
        }
        
        $this->_iRowsAffected = mysql_affected_rows($oResource);
        mysql_free_result($oResource);        
        $this->_isError = false;
        $this->_sMensaje = "executed: $sSQL";
        return true;
    }
   
    private function execute_mssql($sSQL)
    {
        //Cuando se recupera un objeto desde sesion no cuenta
        //con linkid (linkid = 0)
        $oLinkId = $this->_oLinkId;
        if(empty($oLinkId))
            $this->conectar();

        try
        {
            $sSQL = iconv("utf-8", "windows-1252", $sSQL);
            $oResource = mssql_query($sSQL);
            //if $oResource = false 
            if(!$oResource)
            {
                $sMensaje  = "Sentencia SQL con errores: ".mssql_error()."\n";
                $sMensaje .= "\nSQL = $sSQL";
                $this->_isError = true;
                $this->_sMensaje = $sMensaje;
                return -1;
            }
        }
        catch(Exception $e)
        {
            $sMensaje  = "Excepción: ".$e->getMessage()."\n";
            $sMensaje .= "\nSQL = $sSQL";
            $this->_isError = true;
            $this->_sMensaje = $sMensaje;
            return -1;
        }
        
        $this->_iRowsAffected = mssql_affected_rows($oResource);
        mssql_free_result($oResource);        
        $this->_isError = false;
        $this->_sMensaje = "executed: $sSQL";
        return true;
    }  

    public function execute($sSQL)
    {
        $sTipoBD = $this->_sTipoBD;
        switch ($sTipoBD)
        {
            case "mysql":
                return $this->execute_mysql($sSQL);
            break;
            case "sqlserver":
                return $this->execute_mssql($sSQL);
            break;
            default:
            break;
        }
        return null;
    }
    //==================== FIN EXECUTE ================================
    
    //================== GET ==================================
    private function get_servidor()
    {
        return $this->_sServidor;
    }

    public function get_usuario()
    {
        return $this->_sUsuario;
    }

    private function get_clave()
    {
        return $this->_sClave;
    }

    public function get_mensaje()
    {
        return $this->_sMensaje;
    }
   
    public function get_nombre_bd()
    {
        return $this->_sNombreBD;
    }

    private function get_link_id()
    {
        return $this->_oLinkId;
    }        
   
    public function get_tipo_bd()
    {
        return $this->_sTipoBD;
    }
    
    public function is_error()
    {
        return $this->_isError;
    }
    
    public function get_rows_afected()
    {
        return $this->_iRowsAffected;
    }
}
?>

Utilización de CBaseDatos mejorada


<?php
//Archivo de configuración. 
//"config_it.inc"
//La ip o el nombre dns.
define("TFW_DB_SERVER","192.168.15.45");
//El nombre de la base de datos
define("TFW_DB_NAME","mssql_elchalan");
define("TFW_DB_USER","a_user");
define("TFW_DB_PASSWORD","his_password");
//Es una base de datos que corre bajo SQLSERVER2008 R2
define("TFW_DB_TYPE","sqlserver");
...
?>

<?php
//Al no pasar argumentos a get_instancia automaticamente se recuperan
//desde las constantes.
//Creamos el objeto de tipo CBaseDatos
$oBD = CBaseDatos::get_instancia();
//Conectamos y obtenemos el resultado
$isConnected = $oBD->conectar();
//La función bug() es un var_dump customizado
//bug($isConnected);
//bug($oBD);
//En este punto podriamos enviar un mensaje y terminar el script si no se ha podido
//conectar con la Base de datos.

//Creamos nuestra SQL
$sSQL = "SELECT * FROM blog_usuario";
//Utilizamos query para lectura
$arTabla = $oBD->query($sSQL);
bug($arTabla);
$sSQL = "INSERT INTO blog_usuario (id_creador)
         VALUES (2)";
//Utilizamos execute para escritura.
$oBD->execute($sSQL);
$sSQL = "DELETE FROM blog_usuario WHERE id_creador=2";
$oBD->execute($sSQL);
bug($oBD->get_mensaje());
?>

Utilización de CBaseDatos en MVC


<?php
//La clase CBaseDatos
include_once("component_base_datos.php");
class ModelUsuario
{
    private $_oDB = null;
    ...

    public function __construct() 
    {
        ...
        $this->_oDB = CBaseDatos::get_instancia();
        ...
    }
    
    public function get_listado()
    {
        $sSQL = "SELECT * FROM blog_users";
        return $this->_oDB->query($sSQL);
    }
    ...
}
...
//Archivo: view_listado.php
class ViewListado
{
    private $_arTabla = array();

    public function __construct() 
    { }
    
    //Pintar pagina html con el listado
    public function show()
    {
        ...
        foreach($this->arTabla ...)
        {
            ...
        }
        ...
    }
    
    public function set_params($arArray)
    {
        $this->_arTabla = $arArray;
    }
}
...
include_once("model_usuario.php");
include_once("view_listado.php");
class ControllerUsuarios
{
    public function __construct() 
    { }
    
    public function listar()
    {
        $oUsuario = new ModelUsuario();
        $arUsuarios = $oUsuario->get_listado();
        $oViewListado = new ViewListado();
        $oViewListado->set_params($arUsuarios);
    }
    ...
}
?>

Autor: Eduardo A. F.
Publicado: 04-05-2012 16:19
Actualizado: 10-06-2012 17:47

#c# #cloud #css #docker #git #javascript #linux #php #python #sql