通用的数据库访问解决方案

复制内容到剪贴板

代码:

function connectDB($db)
{
        global $host ,$database,$username,$password;
        switch ($db)
        {
                case("psql"):
                        $conn_string="host=".$host."$dbname=".$database."user=".$username."password=".$password;
                        $dbconn=pg_connect($conn_string)or die("Error Connecting to PostgreSQL DB");
                        return $dbconn;
                        break;
                case("mysql"):
                        $dbconn=mysql_connect($host,$username,$password) or die("Error to Connecting to MySQL DB");
                        return $dbconn;
                        break;
                case("mssql"):
                        $dbconn=mssql_connect($host,$username,$password)or die("Error Connecting to MSSQL DB");
                        return $dbconn;
                        break;
                        default;
                        echo "<P> Invalid Database : $db";
                        return 0;
        }
}
function  selectDB($db)
{
        global $database;
        switch ($db)
        {
                case("psql"):
                        return 1;
                        break;
                case("mysql"):
                        mysql_select_db($database)or die("Error Connecting to MySQL DB");
                        return 1;
                        break;
                case("mssql"):
                        mssql_select_db($database)or die("Error Connecting to MS SQL DB");
                        return 1;
                        break;
                        default;
                        echo"<p>Invalid Database : $db";
                        return 0;
        }
}
function queryDB($db,$query)
{
        switch ($db)
        {
                case("psql"):
                        if(! $result = @pg_exec($query))
                        {
                                $result=0;
                        }
                        break;
                case("mysql"):
                        if(!$result = @mysql_query($query))
                        {
                                $result=0;
                        }
                        break;
                case("mssql"):
                        if(!$result=@mssql_query($query))
                        {
                                $result=0;
                        }
                        break;
                        default:;
                        echo"<p>Invalid Database; $db";
                        $result=0;
        }
        return $result;
}
function returnDBarray($db,$result)
{
        if($result!="error")
        {
                switch ($db)
                {
                        case("psql"):
                                if(! $array = @pg_fetch_array($result))
                                {
                                        $array=0;
                                }
                                break;
                        case("mysql"):
                                if(! $array=@mysql_fetch_array($result))
                                {
                                        $array=0;
                                }
                                break;
                        case("mssql"):
                                if(!$array=@mssql_fetch_array($result))
                                {
                                        $array=0;
                                }
                                break;
                                default;
                                echo"<P>Invalid Database: $db";
                                $array=0;
                }
                return $array;
        }
        
}
function closeDB($db,$dbconn)
{
        switch ($db)
        {
                case("psql"):
                        if(!@pg_close($dbconn))
                        {
                                return 0;
                        }
                        else
                        {
                                return 1;
                        }
                        break;
                case("mysql"):
                        if(!@mysql_close($dbconn))
                        {
                                return 0;
                        }
                        else
                        {
                                return 1;
                        }
                        break;
                case("mssql"):
                        if(!@mssql_close($dbconn))
                        {
                                return 0 ;
                        }
                        else
                        {
                                return 1;
                        }
                        break;
                        default;
                        echo "<P> Invalid Database: $db";
                        return  0 ;
        }
}
function numrowsDB($db,$result)
{
        switch ($db)
        {
                case("psql"):
                        if(! $rows = @pg_num_rows($result))
                        {
                                return 0 ;
                        }
                        else
                        {
                                return $rows;
                        }
                        break;
                case("mysql"):
                        if(!$rows=@mysql_num_rows($result))
                        {
                                return 0 ;
                        }
                        else
                        {
                                return $rows;
                        }
                        break;
                case("mssql"):
                        if(!$rows=@mssql_num_rows($result))
                        {
                                return 0 ;
                        }
                        else
                        {
                                return $rows;
                        }
                        break;
                        default;
                        echo "<P> Invalid Database: $db";
                        return  0 ;
                        
        }
}