Linux下使用PHP5.6和SQLServer2008

  今天在某项目上又实然要使用SQL Server 2008，然后折腾了一翻，在紧张的工期内，终于完成了，实乃不易，特此记录下来，免后人继续踩坑。PHP的最佳搭档是MYSQL，就像ASP.NET的最佳搭档是 SQL SERVER一样。在windows下使用PHP连接SQL SERVER应该没难度，因为都是微软系的。但是我们生产环境是Linux所以不得不折腾。

环境：

• CentOS 7.2 64位
• PHP 5.6.29
• SQL Server 2008
• Freetds-1.00.48

首先，安装扩展
PHP有很多数据库扩展，针对不同的数据库系统，这里我们选择使用PDO方式连接SQL Server数据库，那么我们还需要一个 具体数据库的 PDO 驱动 来访问数据库服务，即"pdo_dblib"扩展。

1. 找到php-5.6.29的源码,进入到ext下面，我们可以看到一个pdo_dblib的文件夹，即 /root/php-5.6.29/ext/pdo_dblib

2. 切换到/root/php-5.6.29/ext/pdo_dblib之后，按正常操作应该是执行：

   # /usr/local/php56/bin/phpize 
   # ./configure --with-php-config=/usr/local/php56/bin/php-config 
   

但是，那会报一个错误 ，就是找不到FreeTDS，如下图：

error : Cannot find FreeTDS in knows installaction directories

3. 下载安装FreeTDS

   # wget ftp://ftp.freetds.org/pub/freetds/stable/freetds-patched.tar.gz
   # tar -zxvf freetds-patched.tar.gz 
   # cd freetds-1.00.48/
   # ./configure --prefix=/usr/local/freetds --with-tdsver=7.3 --enable-msdblib
   # make && make install
   

   注：1. 什么是FreeTDS  2. tdsver为什么是7.3

4. 测试FreeTDS

   # /usr/local/freetds/bin/tsql -C
   # /usr/local/freetds/bin/tsql -H 127.0.0.1 -p 1433 -U xxx -P xxx
   

/usr/local/freetds/bin/tsql -C

5. 安装pdo_dblib扩展

   # /usr/local/php56/bin/phpize
   # ./configure --with-php-config=/usr/local/php56/bin/php-config --with-pdo-dblib=/usr/local/freetds/
   # make && make install
   # vim php.ini  添加 extension="pdo_dblib.so"
   

6. 查看扩展及重启PHP

   # php56 -m
   # /etc/init.d/php-fpm56 restart
   

phpinfo()

使用PDO连接SQLServer2008
下面不多说，直接贴出项目代码：

<?php

/**
 * Class Dblib
 */
class Dblib{

    const SQL_SERVER2008_HOST = '127.0.0.1';
    const SQL_SERVER2008_PORT = 1433;
    const SQL_SERVER2008_NAME = 'db_qyim';
    const SQL_SERVER2008_USER = 'XXX';
    const SQL_SERVER2008_PASS = 'XXX';
    const SQL_SERVER2008_DEBUG = true;
    private static $pdo = null;

    public function __construct()
    {
        if(!isset(self::$pdo) || empty(self::$pdo))
            self::$pdo = new PDO('dblib:host='.self::SQL_SERVER2008_HOST.':'.self::SQL_SERVER2008_PORT.';dbname='.self::SQL_SERVER2008_NAME,self::SQL_SERVER2008_USER,self::SQL_SERVER2008_PASS);
    }

    /**
     * @param $sql
     * @param null $msg
     * @return bool|int
     */
    public function execute($sql,&$msg=null)
    {
        try
        {
            $fruit = self::$pdo->exec($sql);
        }
        catch(Exception $e)
        {
            $msg = $e->getMessage();
            $fruit = false;
        }
        if(self::SQL_SERVER2008_DEBUG && self::SQL_SERVER2008_DEBUG == true)
        {
            self::err($sql);
            self::err('-----------------------------------------');
            self::err(self::$pdo->errorInfo());
        }
        return $fruit;
    }

    public function insert($sql,&$msg=null)
    {
        if($this->execute($sql,$msg))
        {
            return $this->getLastId();
        }
        return false;
    }

    public function getList($sql,&$msg=null)
    {
        $fruit = array();
        $sth = self::$pdo->prepare($sql);
        $sth->execute();
        while ($row = $sth->fetch(PDO::FETCH_ASSOC))//返回一个关联数组PDO::FETCH_ASSOC
        {
            $fruit[] = $row;
        }
        return $fruit;
    }

    public function getRow($sql,&$msg=null)
    {
        $result = $this->getList($sql,$msg);
        if(!empty($result) && !empty($result[0]))
        {
            return $result[0];
        }
        $msg = 'The result is empty';
        return array();
    }

    public function arr2insertsql($data,$table_name='')
    {
        $fields = implode(',',array_keys($data));
        $values = implode('\',\'',$data);
        $sql = 'INSERT INTO '.$table_name.'('.$fields.') VALUES (\''.$values.'\');';
        return $sql;
    }

    public function getLastId()
    {
        $sql = "select  @@identity  as  id ;";
        $result = $this->getRow($sql);
        if($result && $result['id'])
        {
            return $result['id'];
        }
        return false;
    }

    public static function err($data = '',$pr='info')
    {
        error_log(date('Y-m-d H:i:s').' '.$pr.' : '.var_export($data,1).PHP_EOL,3,'/tmp/zzz.sqlserver2008.'.$pr.'.'.date('Y-m-d').'.logs');
    }

    /**
     * 创建用户，直接调用该存储过程
     * @param null $name
     * @return string 成功后的用户ID
     */
    public function callCreateUser($name = null)
    {
        $sql = <<<db
exec dbo.CreateUser @name=N'{$name}', -- nvarchar(256)
    @nickname=N'{$name}', -- nvarchar(256)
    @password=N'', -- nvarchar(256)
    @email=N'', -- nvarchar(256)
    @deptId=0, -- int
    @subType=0 -- int
db;
        $sth = self::$pdo->prepare($sql);
        $sth->execute();
        $result = $sth->fetchColumn();
        return $result;
    }

    /**
     * 创建多人会话，直接调用该存储过程
     * @param null $master
     * @param array $members
     * @return string 成功后的会话ID
     */
    public function callCreateTempGroup($master = null,$members = array())
    {
        $users = implode(',',$members);
        $sql = <<<db
exec dbo.CreateTempGroup @creator={$master}, -- int
    @members=N'{$users}' -- nvarchar(4000)
db;
        $sth = self::$pdo->prepare($sql);
        $sth->execute();
        $result = $sth->fetchColumn();
        return $result;
    }

    /**
     * 创建群组，直接调用该存储过程
     * @param null $master
     * @param null $name
     * @return string 成功后的群组ID
     */
    public function callCreateGroup($master = null,$name = null)
    {

        $sql = <<<db
exec dbo.CreateGroup @creator={$master}, -- int
    @name=N'{$name}', -- nvarchar(256)
    @nickname=N'{$name}', -- nvarchar(256)
    @deptId=0, -- int
    @subType=0, -- int
    @remark=N'{$name}' -- nvarchar(1024)
db;
        $sth = self::$pdo->prepare($sql);
        $sth->execute();
        $result = $sth->fetchColumn();
        return $result;
    }
}
$db = new Dblib();
$sql = "SELECT top 1 * FROM Users;";
var_dump($db->getList($sql));

最后，执行结果

SELECT top 1 * FROM Users