fix MsCOmmon.inc
This commit is contained in:
v-kaywon
parent
c508a84ef1
commit
d1df11d035
|
|
@ -1,10 +1,10 @@
|
|||
<?php
|
||||
/*
|
||||
Microsoft SQL Server Driver for PHP - Unit Test Framework
|
||||
Copyright (c) Microsoft Corporation. All rights reserved.
|
||||
Microsoft SQL Server Driver for PHP - Unit Test Framework
|
||||
Copyright (c) Microsoft Corporation. All rights reserved.
|
||||
|
||||
Description:
|
||||
Common functions (shared by all tests).
|
||||
Description:
|
||||
Common functions (shared by all tests).
|
||||
|
||||
*/
|
||||
|
||||
|
|
@ -23,9 +23,9 @@ function connect($options=array())
|
|||
require 'MsSetup.inc';
|
||||
$conn = new PDO( "sqlsrv:Server=$server;database=$databaseName;ConnectionPooling=false;" , $uid, $pwd, $options);
|
||||
$conn->setAttribute( PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION );
|
||||
create_and_insert_table1($conn);
|
||||
create_and_insert_table2($conn);
|
||||
return $conn;
|
||||
create_and_insert_table1($conn);
|
||||
create_and_insert_table2($conn);
|
||||
return $conn;
|
||||
}
|
||||
|
||||
catch( PDOException $e )
|
||||
|
|
@ -54,13 +54,13 @@ function create_and_insert_table1( $conn )
|
|||
DROP TABLE " . $table1 .
|
||||
|
||||
" CREATE TABLE [dbo].[" . $table1 . "](
|
||||
[IntCol] [int] NULL,
|
||||
[CharCol] [char](10) NULL,
|
||||
[NCharCol] [nchar](10) NULL,
|
||||
[DateTimeCol] [datetime] NULL,
|
||||
[VarcharCol] [varchar](50) NULL,
|
||||
[NVarCharCol] [nvarchar](50) NULL,
|
||||
[FloatCol] [float] NULL,
|
||||
[IntCol] [int] NULL,
|
||||
[CharCol] [char](10) NULL,
|
||||
[NCharCol] [nchar](10) NULL,
|
||||
[DateTimeCol] [datetime] NULL,
|
||||
[VarcharCol] [varchar](50) NULL,
|
||||
[NVarCharCol] [nvarchar](50) NULL,
|
||||
[FloatCol] [float] NULL,
|
||||
[XmlCol] [xml] NULL
|
||||
) ON [PRIMARY]
|
||||
";
|
||||
|
|
@ -103,37 +103,37 @@ function create_and_insert_table2( $conn )
|
|||
"IF EXISTS (SELECT * FROM sys.objects WHERE object_id = OBJECT_ID(N'".$table2."') AND type in (N'U')) DROP TABLE " . $table2 .
|
||||
|
||||
" CREATE TABLE " .$table2 . " (
|
||||
[BigIntCol] [bigint] NULL,
|
||||
[BinaryCol] [binary](5) NULL,
|
||||
[BitCol] [bit] NULL,
|
||||
[CharCol] [char](10) NULL,
|
||||
[DateCol] [date] NULL,
|
||||
[DateTimeCol] [datetime] NULL,
|
||||
[DateTime2Col] [datetime2](7) NULL,
|
||||
[DTOffsetCol] [datetimeoffset](7) NULL,
|
||||
[DecimalCol] [decimal](18, 0) NULL,
|
||||
[FloatCol] [float] NULL,
|
||||
[ImageCol] [image] NULL,
|
||||
[IntCol] [int] NULL,
|
||||
[MoneyCol] [money] NULL,
|
||||
[NCharCol] [nchar](10) NULL,
|
||||
[NTextCol] [ntext] NULL,
|
||||
[NumCol] [numeric](18, 0) NULL,
|
||||
[NVarCharCol] [nvarchar](50) NULL,
|
||||
[NVarCharMaxCol] [nvarchar](max) NULL,
|
||||
[RealCol] [real] NULL,
|
||||
[SmallDTCol] [smalldatetime] NULL,
|
||||
[SmallIntCol] [smallint] NULL,
|
||||
[SmallMoneyCol] [smallmoney] NULL,
|
||||
[TextCol] [text] NULL,
|
||||
[TimeCol] [time](7) NULL,
|
||||
[TinyIntCol] [tinyint] NULL,
|
||||
[Guidcol] [uniqueidentifier] NULL,
|
||||
[VarbinaryCol] [varbinary](50) NULL,
|
||||
[VarbinaryMaxCol] [varbinary](max) NULL,
|
||||
[VarcharCol] [varchar](50) NULL,
|
||||
[VarcharMaxCol] [varchar](max) NULL,
|
||||
[XmlCol] [xml] NULL
|
||||
[BigIntCol] [bigint] NULL,
|
||||
[BinaryCol] [binary](5) NULL,
|
||||
[BitCol] [bit] NULL,
|
||||
[CharCol] [char](10) NULL,
|
||||
[DateCol] [date] NULL,
|
||||
[DateTimeCol] [datetime] NULL,
|
||||
[DateTime2Col] [datetime2](7) NULL,
|
||||
[DTOffsetCol] [datetimeoffset](7) NULL,
|
||||
[DecimalCol] [decimal](18, 0) NULL,
|
||||
[FloatCol] [float] NULL,
|
||||
[ImageCol] [image] NULL,
|
||||
[IntCol] [int] NULL,
|
||||
[MoneyCol] [money] NULL,
|
||||
[NCharCol] [nchar](10) NULL,
|
||||
[NTextCol] [ntext] NULL,
|
||||
[NumCol] [numeric](18, 0) NULL,
|
||||
[NVarCharCol] [nvarchar](50) NULL,
|
||||
[NVarCharMaxCol] [nvarchar](max) NULL,
|
||||
[RealCol] [real] NULL,
|
||||
[SmallDTCol] [smalldatetime] NULL,
|
||||
[SmallIntCol] [smallint] NULL,
|
||||
[SmallMoneyCol] [smallmoney] NULL,
|
||||
[TextCol] [text] NULL,
|
||||
[TimeCol] [time](7) NULL,
|
||||
[TinyIntCol] [tinyint] NULL,
|
||||
[Guidcol] [uniqueidentifier] NULL,
|
||||
[VarbinaryCol] [varbinary](50) NULL,
|
||||
[VarbinaryMaxCol] [varbinary](max) NULL,
|
||||
[VarcharCol] [varchar](50) NULL,
|
||||
[VarcharMaxCol] [varchar](max) NULL,
|
||||
[XmlCol] [xml] NULL
|
||||
) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY]
|
||||
|
||||
";
|
||||
|
|
@ -205,961 +205,997 @@ function my_print_r( $to_print )
|
|||
|
||||
function TestMode()
|
||||
{
|
||||
$testMode = getenv('PHPT_EXEC');
|
||||
return ($testMode ? true : false);
|
||||
$testMode = getenv('PHPT_EXEC');
|
||||
return ($testMode ? true : false);
|
||||
}
|
||||
|
||||
function IsPdoMode()
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
return (($driverType === true) ? true : false);
|
||||
require 'MsSetup.inc';
|
||||
return (($driverType === true) ? true : false);
|
||||
}
|
||||
|
||||
|
||||
function TraceMode()
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
return ((!TestMode() && $traceEnabled) ? true : false);
|
||||
require 'MsSetup.inc';
|
||||
return ((!TestMode() && $traceEnabled) ? true : false);
|
||||
}
|
||||
|
||||
function IsMarsSupported()
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
return ($marsMode ? true : false);
|
||||
require 'MsSetup.inc';
|
||||
return ($marsMode ? true : false);
|
||||
}
|
||||
|
||||
function IsDaasMode()
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
return ($daasMode ? true : false);
|
||||
require 'MsSetup.inc';
|
||||
return ($daasMode ? true : false);
|
||||
}
|
||||
|
||||
function FatalError($errorMsg)
|
||||
{
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
handle_errors();
|
||||
}
|
||||
die("$errorMsg\n");
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
handle_errors();
|
||||
}
|
||||
die("$errorMsg\n");
|
||||
}
|
||||
|
||||
function Trace($msg)
|
||||
{
|
||||
if (TraceMode())
|
||||
{
|
||||
echo $msg;
|
||||
}
|
||||
if (TraceMode())
|
||||
{
|
||||
echo $msg;
|
||||
}
|
||||
}
|
||||
|
||||
function TraceEx($msg, $exitMode)
|
||||
{
|
||||
if ($exitMode)
|
||||
{
|
||||
FatalError($msg);
|
||||
}
|
||||
else
|
||||
{
|
||||
Trace("$msg\n");
|
||||
}
|
||||
if ($exitMode)
|
||||
{
|
||||
FatalError($msg);
|
||||
}
|
||||
else
|
||||
{
|
||||
Trace("$msg\n");
|
||||
}
|
||||
}
|
||||
|
||||
function TraceData($sqlType, $data)
|
||||
{
|
||||
if (TraceMode())
|
||||
{
|
||||
$msg = strtoupper(" $sqlType:");
|
||||
echo "$msg\t";
|
||||
if (strlen($msg) <= 7)
|
||||
{
|
||||
echo "\t";
|
||||
}
|
||||
if (strlen($msg) <= 15)
|
||||
{
|
||||
echo "\t";
|
||||
}
|
||||
echo "$data\n"
|
||||
if (TraceMode())
|
||||
{
|
||||
$msg = strtoupper(" $sqlType:");
|
||||
echo "$msg\t";
|
||||
if (strlen($msg) <= 7)
|
||||
{
|
||||
echo "\t";
|
||||
}
|
||||
if (strlen($msg) <= 15)
|
||||
{
|
||||
echo "\t";
|
||||
}
|
||||
echo "$data\n"
|
||||
;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function StartTest($testName)
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
require 'MsSetup.inc';
|
||||
|
||||
if (TraceMode())
|
||||
{
|
||||
echo "$PhpDriver: starting \"$testName\" test...\n\n";
|
||||
}
|
||||
if (TraceMode())
|
||||
{
|
||||
echo "$PhpDriver: starting \"$testName\" test...\n\n";
|
||||
}
|
||||
|
||||
if (!extension_loaded(IsPdoMode() ? "pdo" : "sqlsrv"))
|
||||
{
|
||||
die("$PhpDriver cannot be loaded.");
|
||||
}
|
||||
if (!extension_loaded(IsPdoMode() ? "pdo" : "sqlsrv"))
|
||||
{
|
||||
die("$PhpDriver cannot be loaded.");
|
||||
}
|
||||
|
||||
// Set timezone
|
||||
$tz = ini_get('date.timezone');
|
||||
if (strcmp($tz, "") == 0)
|
||||
{
|
||||
date_default_timezone_set('America/Los_Angeles');
|
||||
$tz = date_default_timezone_get();
|
||||
}
|
||||
Trace("Timezone: $tz.\n");
|
||||
// Set timezone
|
||||
$tz = ini_get('date.timezone');
|
||||
if (strcmp($tz, "") == 0)
|
||||
{
|
||||
date_default_timezone_set('America/Los_Angeles');
|
||||
$tz = date_default_timezone_get();
|
||||
}
|
||||
Trace("Timezone: $tz.\n");
|
||||
}
|
||||
|
||||
function EndTest($testName)
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
require 'MsSetup.inc';
|
||||
|
||||
if (TraceMode())
|
||||
{
|
||||
echo "\n$PhpDriver: "
|
||||
if (TraceMode())
|
||||
{
|
||||
echo "\n$PhpDriver: "
|
||||
;
|
||||
}
|
||||
echo "Test \"$testName\" completed successfully.\n"
|
||||
}
|
||||
echo "Test \"$testName\" completed successfully.\n"
|
||||
;
|
||||
}
|
||||
|
||||
|
||||
function Setup()
|
||||
{
|
||||
set_time_limit(0);
|
||||
set_time_limit(0);
|
||||
|
||||
if (IsPdoMode())
|
||||
{ // PDO setup
|
||||
}
|
||||
else
|
||||
{ // PHP setup
|
||||
sqlsrv_configure('LogSubsystems', SQLSRV_LOG_SYSTEM_ALL);
|
||||
sqlsrv_configure('LogSeverity', SQLSRV_LOG_SEVERITY_ALL);
|
||||
sqlsrv_configure('WarningsReturnAsErrors', 1);
|
||||
}
|
||||
if (IsPdoMode())
|
||||
{ // PDO setup
|
||||
}
|
||||
else
|
||||
{ // PHP setup
|
||||
sqlsrv_configure('LogSubsystems', SQLSRV_LOG_SYSTEM_ALL);
|
||||
sqlsrv_configure('LogSeverity', SQLSRV_LOG_SEVERITY_ALL);
|
||||
sqlsrv_configure('WarningsReturnAsErrors', 1);
|
||||
}
|
||||
}
|
||||
|
||||
function Configure($param, $expected)
|
||||
{
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
sqlsrv_configure($param, $expected);
|
||||
$actual = sqlsrv_get_config($param);
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
sqlsrv_configure($param, $expected);
|
||||
$actual = sqlsrv_get_config($param);
|
||||
|
||||
if ($actual == $expected)
|
||||
{
|
||||
Trace("Set configuration parameter $param = $actual.\n");
|
||||
}
|
||||
else
|
||||
{
|
||||
die("Failed to set configuration parameter $param = $expected.");
|
||||
}
|
||||
}
|
||||
if ($actual == $expected)
|
||||
{
|
||||
Trace("Set configuration parameter $param = $actual.\n");
|
||||
}
|
||||
else
|
||||
{
|
||||
die("Failed to set configuration parameter $param = $expected.");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function GetTempTableName($table = '', $temporary = true)
|
||||
{
|
||||
// A temporary table name with the '#' prefix will be automatically
|
||||
// dropped once the connection is closed. Otherwise, the caller
|
||||
// should take care of dropping the temp table afterwards.
|
||||
|
||||
$timestamp = round(microtime(true)*1000);
|
||||
|
||||
$prefix = '';
|
||||
if ($temporary)
|
||||
$prefix = '#';
|
||||
|
||||
if (strlen($table) == 0)
|
||||
$table = 'php_test_table';
|
||||
|
||||
return $prefix . $table . '_' . $timestamp;
|
||||
}
|
||||
|
||||
function GetTempProcName($proc = '', $temporary = true)
|
||||
{
|
||||
// A temporary stored procedure name with the '#' prefix will be
|
||||
// automatically dropped once the connection is closed. Otherwise,
|
||||
// the caller should take care of dropping the temp procedure afterwards.
|
||||
|
||||
$timestamp = round(microtime(true)*1000);
|
||||
|
||||
$prefix = '';
|
||||
if ($temporary)
|
||||
$prefix = '#';
|
||||
|
||||
if (strlen($proc) == 0)
|
||||
$proc = 'php_test_proc';
|
||||
|
||||
return $prefix . $proc . '_' . $timestamp;
|
||||
}
|
||||
|
||||
function PDOConnect($className, $serverName, $user, $pwd, $exitMode)
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
$conn = null;
|
||||
|
||||
try
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
$conn = null;
|
||||
|
||||
try
|
||||
{
|
||||
// simply use $databaseName from MsSetup.inc to facilitate testing in Azure,
|
||||
// which does not support switching databases
|
||||
$conn = new $className("sqlsrv:Server=$serverName;Database=$databaseName", $user, $pwd, $connectionOptions);
|
||||
$conn->setAttribute(PDO::SQLSRV_ATTR_ENCODING, PDO::SQLSRV_ENCODING_SYSTEM);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$conn = null;
|
||||
TraceEx("\nFailed to connect to $serverName: ".$e->getMessage(), $exitMode);
|
||||
}
|
||||
$conn = new $className("sqlsrv:Server=$serverName;Database=$databaseName", $user, $pwd, $connectionOptions);
|
||||
$conn->setAttribute(PDO::SQLSRV_ATTR_ENCODING, PDO::SQLSRV_ENCODING_SYSTEM);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$conn = null;
|
||||
TraceEx("\nFailed to connect to $serverName: ".$e->getMessage(), $exitMode);
|
||||
}
|
||||
|
||||
return ($conn);
|
||||
return ($conn);
|
||||
}
|
||||
|
||||
|
||||
function ExecuteQuery($conn, $tsql)
|
||||
{
|
||||
$stmt = null;
|
||||
$stmt = null;
|
||||
|
||||
if (IsPdoMode())
|
||||
{ // PDO
|
||||
try
|
||||
{
|
||||
$stmt = $conn->query($tsql);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$stmt = null;
|
||||
FatalError("Query execution failed for $tsql: ".$e->getMessage());
|
||||
}
|
||||
}
|
||||
else
|
||||
{ // PHP
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Query execution failed for $tsql");
|
||||
}
|
||||
}
|
||||
return ($stmt);
|
||||
if (IsPdoMode())
|
||||
{ // PDO
|
||||
try
|
||||
{
|
||||
$stmt = $conn->query($tsql);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$stmt = null;
|
||||
FatalError("Query execution failed for $tsql: ".$e->getMessage());
|
||||
}
|
||||
}
|
||||
else
|
||||
{ // PHP
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Query execution failed for $tsql");
|
||||
}
|
||||
}
|
||||
return ($stmt);
|
||||
}
|
||||
|
||||
|
||||
function PrepareQuery($conn, $tsql)
|
||||
{
|
||||
$stmt = null;
|
||||
$stmt = null;
|
||||
|
||||
if (IsPdoMode())
|
||||
{ // PDO
|
||||
try
|
||||
{
|
||||
$stmt = $conn->prepare($tsql);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$stmt = null;
|
||||
FatalError("Query preparation failed for $tsql: ".$e->getMessage());
|
||||
}
|
||||
}
|
||||
else
|
||||
{ // PHP
|
||||
$stmt = sqlsrv_prepare($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Query preparation failed for $tsql");
|
||||
}
|
||||
}
|
||||
if (IsPdoMode())
|
||||
{ // PDO
|
||||
try
|
||||
{
|
||||
$stmt = $conn->prepare($tsql);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$stmt = null;
|
||||
FatalError("Query preparation failed for $tsql: ".$e->getMessage());
|
||||
}
|
||||
}
|
||||
else
|
||||
{ // PHP
|
||||
$stmt = sqlsrv_prepare($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Query preparation failed for $tsql");
|
||||
}
|
||||
}
|
||||
|
||||
return ($stmt);
|
||||
return ($stmt);
|
||||
}
|
||||
|
||||
|
||||
function ExecuteQueryEx($conn, $tsql, $modeDirect)
|
||||
{
|
||||
$stmt = null;
|
||||
$stmt = null;
|
||||
|
||||
if ($modeDirect)
|
||||
{ // direct execution
|
||||
if (IsPdoMode())
|
||||
{ // PDO
|
||||
try
|
||||
{
|
||||
$stmt = $conn->query($tsql);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$stmt = null;
|
||||
}
|
||||
}
|
||||
else
|
||||
{ // PHP
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = PrepareQuery($conn, $tsql);
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt->execute();
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_execute($stmt);
|
||||
}
|
||||
}
|
||||
if ($modeDirect)
|
||||
{ // direct execution
|
||||
if (IsPdoMode())
|
||||
{ // PDO
|
||||
try
|
||||
{
|
||||
$stmt = $conn->query($tsql);
|
||||
}
|
||||
catch (PDOException $e)
|
||||
{
|
||||
$stmt = null;
|
||||
}
|
||||
}
|
||||
else
|
||||
{ // PHP
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = PrepareQuery($conn, $tsql);
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt->execute();
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_execute($stmt);
|
||||
}
|
||||
}
|
||||
|
||||
return ($stmt);
|
||||
return ($stmt);
|
||||
}
|
||||
|
||||
|
||||
function GetSqlType($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return ("int");
|
||||
case 2: return ("tinyint");
|
||||
case 3: return ("smallint");
|
||||
case 4: return ("bigint");
|
||||
case 5: return ("bit");
|
||||
case 6: return ("float");
|
||||
case 7: return ("real");
|
||||
case 8: return ("decimal(28,4)");
|
||||
case 9: return ("numeric(32,4)");
|
||||
case 10: return ("money");
|
||||
case 11: return ("smallmoney");
|
||||
case 12: return ("char(512)");
|
||||
case 13: return ("varchar(512)");
|
||||
case 14: return ("varchar(max)");
|
||||
case 15: return ("nchar(512)");
|
||||
case 16: return ("nvarchar(512)");
|
||||
case 17: return ("nvarchar(max)");
|
||||
case 18: return ("text");
|
||||
case 19: return ("ntext");
|
||||
case 20: return ("binary(512)");
|
||||
case 21: return ("varbinary(512)");
|
||||
case 22: return ("varbinary(max)");
|
||||
case 23: return ("image");
|
||||
case 24: return ("uniqueidentifier");
|
||||
case 25: return ("datetime");
|
||||
case 26: return ("smalldatetime");
|
||||
case 27: return ("timestamp");
|
||||
case 28: return ("xml");
|
||||
default: break;
|
||||
}
|
||||
return ("udt");
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return ("int");
|
||||
case 2: return ("tinyint");
|
||||
case 3: return ("smallint");
|
||||
case 4: return ("bigint");
|
||||
case 5: return ("bit");
|
||||
case 6: return ("float");
|
||||
case 7: return ("real");
|
||||
case 8: return ("decimal(28,4)");
|
||||
case 9: return ("numeric(32,4)");
|
||||
case 10: return ("money");
|
||||
case 11: return ("smallmoney");
|
||||
case 12: return ("char(512)");
|
||||
case 13: return ("varchar(512)");
|
||||
case 14: return ("varchar(max)");
|
||||
case 15: return ("nchar(512)");
|
||||
case 16: return ("nvarchar(512)");
|
||||
case 17: return ("nvarchar(max)");
|
||||
case 18: return ("text");
|
||||
case 19: return ("ntext");
|
||||
case 20: return ("binary(512)");
|
||||
case 21: return ("varbinary(512)");
|
||||
case 22: return ("varbinary(max)");
|
||||
case 23: return ("image");
|
||||
case 24: return ("uniqueidentifier");
|
||||
case 25: return ("datetime");
|
||||
case 26: return ("smalldatetime");
|
||||
case 27: return ("timestamp");
|
||||
case 28: return ("xml");
|
||||
default: break;
|
||||
}
|
||||
return ("udt");
|
||||
}
|
||||
|
||||
function GetDriverType($k, $dataSize)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return (SQLSRV_SQLTYPE_INT);
|
||||
case 2: return (SQLSRV_SQLTYPE_TINYINT);
|
||||
case 3: return (SQLSRV_SQLTYPE_SMALLINT);
|
||||
case 4: return (SQLSRV_SQLTYPE_BIGINT);
|
||||
case 5: return (SQLSRV_SQLTYPE_BIT);
|
||||
case 6: return (SQLSRV_SQLTYPE_FLOAT);
|
||||
case 7: return (SQLSRV_SQLTYPE_REAL);
|
||||
case 8: return (SQLSRV_SQLTYPE_DECIMAL(28, 4));
|
||||
case 9: return (SQLSRV_SQLTYPE_NUMERIC(32, 4));
|
||||
case 10: return (SQLSRV_SQLTYPE_MONEY);
|
||||
case 11: return (SQLSRV_SQLTYPE_SMALLMONEY);
|
||||
case 12: return (SQLSRV_SQLTYPE_CHAR($dataSize));
|
||||
case 13: return (SQLSRV_SQLTYPE_VARCHAR($dataSize));
|
||||
case 14: return (SQLSRV_SQLTYPE_VARCHAR('max'));
|
||||
case 15: return (SQLSRV_SQLTYPE_NCHAR($dataSize));
|
||||
case 16: return (SQLSRV_SQLTYPE_NVARCHAR($dataSize));
|
||||
case 17: return (SQLSRV_SQLTYPE_NVARCHAR('max'));
|
||||
case 18: return (SQLSRV_SQLTYPE_TEXT);
|
||||
case 19: return (SQLSRV_SQLTYPE_NTEXT);
|
||||
case 20: return (SQLSRV_SQLTYPE_BINARY($dataSize));
|
||||
case 21: return (SQLSRV_SQLTYPE_VARBINARY($dataSize));
|
||||
case 22: return (SQLSRV_SQLTYPE_VARBINARY('max'));
|
||||
case 23: return (SQLSRV_SQLTYPE_IMAGE);
|
||||
case 24: return (SQLSRV_SQLTYPE_UNIQUEIDENTIFIER);
|
||||
case 25: return (SQLSRV_SQLTYPE_DATETIME);
|
||||
case 26: return (SQLSRV_SQLTYPE_SMALLDATETIME);
|
||||
case 27: return (SQLSRV_SQLTYPE_TIMESTAMP);
|
||||
case 28: return (SQLSRV_SQLTYPE_XML);
|
||||
default: break;
|
||||
}
|
||||
return (SQLSRV_SQLTYPE_UDT);
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return (SQLSRV_SQLTYPE_INT);
|
||||
case 2: return (SQLSRV_SQLTYPE_TINYINT);
|
||||
case 3: return (SQLSRV_SQLTYPE_SMALLINT);
|
||||
case 4: return (SQLSRV_SQLTYPE_BIGINT);
|
||||
case 5: return (SQLSRV_SQLTYPE_BIT);
|
||||
case 6: return (SQLSRV_SQLTYPE_FLOAT);
|
||||
case 7: return (SQLSRV_SQLTYPE_REAL);
|
||||
case 8: return (SQLSRV_SQLTYPE_DECIMAL(28, 4));
|
||||
case 9: return (SQLSRV_SQLTYPE_NUMERIC(32, 4));
|
||||
case 10: return (SQLSRV_SQLTYPE_MONEY);
|
||||
case 11: return (SQLSRV_SQLTYPE_SMALLMONEY);
|
||||
case 12: return (SQLSRV_SQLTYPE_CHAR($dataSize));
|
||||
case 13: return (SQLSRV_SQLTYPE_VARCHAR($dataSize));
|
||||
case 14: return (SQLSRV_SQLTYPE_VARCHAR('max'));
|
||||
case 15: return (SQLSRV_SQLTYPE_NCHAR($dataSize));
|
||||
case 16: return (SQLSRV_SQLTYPE_NVARCHAR($dataSize));
|
||||
case 17: return (SQLSRV_SQLTYPE_NVARCHAR('max'));
|
||||
case 18: return (SQLSRV_SQLTYPE_TEXT);
|
||||
case 19: return (SQLSRV_SQLTYPE_NTEXT);
|
||||
case 20: return (SQLSRV_SQLTYPE_BINARY($dataSize));
|
||||
case 21: return (SQLSRV_SQLTYPE_VARBINARY($dataSize));
|
||||
case 22: return (SQLSRV_SQLTYPE_VARBINARY('max'));
|
||||
case 23: return (SQLSRV_SQLTYPE_IMAGE);
|
||||
case 24: return (SQLSRV_SQLTYPE_UNIQUEIDENTIFIER);
|
||||
case 25: return (SQLSRV_SQLTYPE_DATETIME);
|
||||
case 26: return (SQLSRV_SQLTYPE_SMALLDATETIME);
|
||||
case 27: return (SQLSRV_SQLTYPE_TIMESTAMP);
|
||||
case 28: return (SQLSRV_SQLTYPE_XML);
|
||||
default: break;
|
||||
}
|
||||
return (SQLSRV_SQLTYPE_UDT);
|
||||
}
|
||||
|
||||
function IsStreamable($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return (true); // nchar(512)
|
||||
case 13: return (true); // varchar(512)
|
||||
case 14: return (true); // varchar(max)
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 18: return (true); // text
|
||||
case 19: return (true); // ntext
|
||||
case 20: return (true); // binary
|
||||
case 21: return (true); // varbinary(512)
|
||||
case 22: return (true); // varbinary(max)
|
||||
case 23: return (true); // image
|
||||
case 28: return (true); // xml
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return (true); // nchar(512)
|
||||
case 13: return (true); // varchar(512)
|
||||
case 14: return (true); // varchar(max)
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 18: return (true); // text
|
||||
case 19: return (true); // ntext
|
||||
case 20: return (true); // binary
|
||||
case 21: return (true); // varbinary(512)
|
||||
case 22: return (true); // varbinary(max)
|
||||
case 23: return (true); // image
|
||||
case 28: return (true); // xml
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
}
|
||||
|
||||
function IsNumeric($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return (true); // int
|
||||
case 2: return (true); // tinyint
|
||||
case 3: return (true); // smallint
|
||||
case 4: return (true); // bigint
|
||||
case 5: return (true); // bit
|
||||
case 6: return (true); // float
|
||||
case 7: return (true); // real
|
||||
case 8: return (true); // decimal(28,4)
|
||||
case 9: return (true); // numeric(32,4)
|
||||
case 10: return (true); // money
|
||||
case 11: return (true); // smallmoney
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return (true); // int
|
||||
case 2: return (true); // tinyint
|
||||
case 3: return (true); // smallint
|
||||
case 4: return (true); // bigint
|
||||
case 5: return (true); // bit
|
||||
case 6: return (true); // float
|
||||
case 7: return (true); // real
|
||||
case 8: return (true); // decimal(28,4)
|
||||
case 9: return (true); // numeric(32,4)
|
||||
case 10: return (true); // money
|
||||
case 11: return (true); // smallmoney
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
}
|
||||
|
||||
function IsChar($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return (true); // nchar(512)
|
||||
case 13: return (true); // varchar(512)
|
||||
case 14: return (true); // varchar(max)
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 18: return (true); // text
|
||||
case 19: return (true); // ntext
|
||||
case 28: return (true); // xml
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return (true); // nchar(512)
|
||||
case 13: return (true); // varchar(512)
|
||||
case 14: return (true); // varchar(max)
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 18: return (true); // text
|
||||
case 19: return (true); // ntext
|
||||
case 28: return (true); // xml
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
}
|
||||
|
||||
function IsBinary($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 20: return (true); // binary
|
||||
case 21: return (true); // varbinary(512)
|
||||
case 22: return (true); // varbinary(max)
|
||||
case 23: return (true); // image
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
switch ($k)
|
||||
{
|
||||
case 20: return (true); // binary
|
||||
case 21: return (true); // varbinary(512)
|
||||
case 22: return (true); // varbinary(max)
|
||||
case 23: return (true); // image
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
}
|
||||
|
||||
function IsDateTime($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 25: return (true); // datetime
|
||||
case 26: return (true); // smalldatetime
|
||||
case 27: return (true); // timestamp
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
switch ($k)
|
||||
{
|
||||
case 25: return (true); // datetime
|
||||
case 26: return (true); // smalldatetime
|
||||
case 27: return (true); // timestamp
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
}
|
||||
|
||||
function IsUnicode($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 19: return (true); // ntext
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
switch ($k)
|
||||
{
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 19: return (true); // ntext
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
}
|
||||
|
||||
function IsUpdatable($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 27: return (false); // timestamp
|
||||
default: break;
|
||||
}
|
||||
return (true);
|
||||
switch ($k)
|
||||
{
|
||||
case 27: return (false); // timestamp
|
||||
default: break;
|
||||
}
|
||||
return (true);
|
||||
}
|
||||
|
||||
function IsLiteral($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return (true); // nchar(512)
|
||||
case 13: return (true); // varchar(512)
|
||||
case 14: return (true); // varchar(max)
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 18: return (true); // text
|
||||
case 19: return (true); // ntext
|
||||
case 24: return (true); // uniqueidentifier
|
||||
case 25: return (true); // datetime
|
||||
case 26: return (true); // smalldatetime
|
||||
case 28: return (true); // xml
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return (true); // nchar(512)
|
||||
case 13: return (true); // varchar(512)
|
||||
case 14: return (true); // varchar(max)
|
||||
case 15: return (true); // nchar(512)
|
||||
case 16: return (true); // nvarchar(512)
|
||||
case 17: return (true); // nvarchar(max)
|
||||
case 18: return (true); // text
|
||||
case 19: return (true); // ntext
|
||||
case 24: return (true); // uniqueidentifier
|
||||
case 25: return (true); // datetime
|
||||
case 26: return (true); // smalldatetime
|
||||
case 28: return (true); // xml
|
||||
default: break;
|
||||
}
|
||||
return (false);
|
||||
}
|
||||
|
||||
function GetMetadata($k, $info)
|
||||
{
|
||||
if (strcasecmp($info, 'Name') == 0)
|
||||
{
|
||||
return (getColName($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Size') == 0)
|
||||
{
|
||||
return (getColSize($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Precision') == 0)
|
||||
{
|
||||
return (getColPrecision($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Scale') == 0)
|
||||
{
|
||||
return (getColScale($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Nullable') == 0)
|
||||
{
|
||||
return (getColNullable($k));
|
||||
}
|
||||
return ("");
|
||||
if (strcasecmp($info, 'Name') == 0)
|
||||
{
|
||||
return (getColName($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Size') == 0)
|
||||
{
|
||||
return (getColSize($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Precision') == 0)
|
||||
{
|
||||
return (getColPrecision($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Scale') == 0)
|
||||
{
|
||||
return (getColScale($k));
|
||||
}
|
||||
if (strcasecmp($info, 'Nullable') == 0)
|
||||
{
|
||||
return (getColNullable($k));
|
||||
}
|
||||
return ("");
|
||||
}
|
||||
|
||||
function GetColName($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return ("c1_int");
|
||||
case 2: return ("c2_tinyint");
|
||||
case 3: return ("c3_smallint");
|
||||
case 4: return ("c4_bigint");
|
||||
case 5: return ("c5_bit");
|
||||
case 6: return ("c6_float");
|
||||
case 7: return ("c7_real");
|
||||
case 8: return ("c8_decimal");
|
||||
case 9: return ("c9_numeric");
|
||||
case 10: return ("c10_money");
|
||||
case 11: return ("c11_smallmoney");
|
||||
case 12: return ("c12_char");
|
||||
case 13: return ("c13_varchar");
|
||||
case 14: return ("c14_varchar_max");
|
||||
case 15: return ("c15_nchar");
|
||||
case 16: return ("c16_nvarchar");
|
||||
case 17: return ("c17_nvarchar_max");
|
||||
case 18: return ("c18_text");
|
||||
case 19: return ("c19_ntext");
|
||||
case 20: return ("c20_binary");
|
||||
case 21: return ("c21_varbinary");
|
||||
case 22: return ("c22_varbinary_max");
|
||||
case 23: return ("c23_image");
|
||||
case 24: return ("c24_uniqueidentifier");
|
||||
case 25: return ("c25_datetime");
|
||||
case 26: return ("c26_smalldatetime");
|
||||
case 27: return ("c27_timestamp");
|
||||
case 28: return ("c28_xml");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return ("c1_int");
|
||||
case 2: return ("c2_tinyint");
|
||||
case 3: return ("c3_smallint");
|
||||
case 4: return ("c4_bigint");
|
||||
case 5: return ("c5_bit");
|
||||
case 6: return ("c6_float");
|
||||
case 7: return ("c7_real");
|
||||
case 8: return ("c8_decimal");
|
||||
case 9: return ("c9_numeric");
|
||||
case 10: return ("c10_money");
|
||||
case 11: return ("c11_smallmoney");
|
||||
case 12: return ("c12_char");
|
||||
case 13: return ("c13_varchar");
|
||||
case 14: return ("c14_varchar_max");
|
||||
case 15: return ("c15_nchar");
|
||||
case 16: return ("c16_nvarchar");
|
||||
case 17: return ("c17_nvarchar_max");
|
||||
case 18: return ("c18_text");
|
||||
case 19: return ("c19_ntext");
|
||||
case 20: return ("c20_binary");
|
||||
case 21: return ("c21_varbinary");
|
||||
case 22: return ("c22_varbinary_max");
|
||||
case 23: return ("c23_image");
|
||||
case 24: return ("c24_uniqueidentifier");
|
||||
case 25: return ("c25_datetime");
|
||||
case 26: return ("c26_smalldatetime");
|
||||
case 27: return ("c27_timestamp");
|
||||
case 28: return ("c28_xml");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
}
|
||||
|
||||
|
||||
function GetColSize($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return ("512");
|
||||
case 13: return ("512");
|
||||
case 14: return ("0");
|
||||
case 15: return ("512");
|
||||
case 16: return ("512");
|
||||
case 17: return ("0");
|
||||
case 18: return ("2147483647");
|
||||
case 19: return ("1073741823");
|
||||
case 20: return ("512");
|
||||
case 21: return ("512");
|
||||
case 22: return ("0)");
|
||||
case 23: return ("2147483647");
|
||||
case 24: return ("36");
|
||||
//case 25: return ("23");
|
||||
//case 26: return ("16");
|
||||
case 27: return ("8");
|
||||
case 28: return ("0");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
switch ($k)
|
||||
{
|
||||
case 12: return ("512");
|
||||
case 13: return ("512");
|
||||
case 14: return ("0");
|
||||
case 15: return ("512");
|
||||
case 16: return ("512");
|
||||
case 17: return ("0");
|
||||
case 18: return ("2147483647");
|
||||
case 19: return ("1073741823");
|
||||
case 20: return ("512");
|
||||
case 21: return ("512");
|
||||
case 22: return ("0)");
|
||||
case 23: return ("2147483647");
|
||||
case 24: return ("36");
|
||||
//case 25: return ("23");
|
||||
//case 26: return ("16");
|
||||
case 27: return ("8");
|
||||
case 28: return ("0");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
}
|
||||
|
||||
function GetColPrecision($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return ("10");
|
||||
case 2: return ("3");
|
||||
case 3: return ("5");
|
||||
case 4: return ("19");
|
||||
case 5: return ("1");
|
||||
case 6: return ("53");
|
||||
case 7: return ("24");
|
||||
case 8: return ("28");
|
||||
case 9: return ("32");
|
||||
case 10: return ("19");
|
||||
case 11: return ("10");
|
||||
case 25: return ("23");
|
||||
case 26: return ("16");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
switch ($k)
|
||||
{
|
||||
case 1: return ("10");
|
||||
case 2: return ("3");
|
||||
case 3: return ("5");
|
||||
case 4: return ("19");
|
||||
case 5: return ("1");
|
||||
case 6: return ("53");
|
||||
case 7: return ("24");
|
||||
case 8: return ("28");
|
||||
case 9: return ("32");
|
||||
case 10: return ("19");
|
||||
case 11: return ("10");
|
||||
case 25: return ("23");
|
||||
case 26: return ("16");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
}
|
||||
|
||||
function GetColScale($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 8: return ("4");
|
||||
case 9: return ("4");
|
||||
case 10: return ("4");
|
||||
case 11: return ("4");
|
||||
case 25: return ("3");
|
||||
case 26: return ("0");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
switch ($k)
|
||||
{
|
||||
case 8: return ("4");
|
||||
case 9: return ("4");
|
||||
case 10: return ("4");
|
||||
case 11: return ("4");
|
||||
case 25: return ("3");
|
||||
case 26: return ("0");
|
||||
default: break;
|
||||
}
|
||||
return ("");
|
||||
}
|
||||
|
||||
function GetColNullable($k)
|
||||
{
|
||||
return (IsUpdatable($k) ? "1" : "0");
|
||||
return (IsUpdatable($k) ? "1" : "0");
|
||||
}
|
||||
|
||||
function GetSampleData($k)
|
||||
{
|
||||
switch ($k)
|
||||
{
|
||||
case 1: // int
|
||||
return ("123456789");
|
||||
switch ($k)
|
||||
{
|
||||
case 1: // int
|
||||
return ("123456789");
|
||||
|
||||
case 2: // tinyint
|
||||
return ("234");
|
||||
case 2: // tinyint
|
||||
return ("234");
|
||||
|
||||
case 3: // smallint
|
||||
return ("5678");
|
||||
|
||||
case 4: // bigint
|
||||
return ("123456789987654321");
|
||||
case 3: // smallint
|
||||
return ("5678");
|
||||
|
||||
case 4: // bigint
|
||||
return ("123456789987654321");
|
||||
|
||||
|
||||
case 5: // bit
|
||||
return ("1");
|
||||
case 5: // bit
|
||||
return ("1");
|
||||
|
||||
case 6: // float
|
||||
return ("123.456");
|
||||
case 6: // float
|
||||
return ("123.456");
|
||||
|
||||
case 7: // real
|
||||
return ("789.012");
|
||||
case 7: // real
|
||||
return ("789.012");
|
||||
|
||||
case 8: // decimal
|
||||
return ("12.34");
|
||||
case 8: // decimal
|
||||
return ("12.34");
|
||||
|
||||
case 9: // numeric
|
||||
return ("567.89");
|
||||
case 9: // numeric
|
||||
return ("567.89");
|
||||
|
||||
case 10:// money
|
||||
return ("321.54");
|
||||
case 10:// money
|
||||
return ("321.54");
|
||||
|
||||
case 11:// smallmoney
|
||||
return ("67.89");
|
||||
case 11:// smallmoney
|
||||
return ("67.89");
|
||||
|
||||
case 12:// char
|
||||
case 15:// nchar
|
||||
return ("The quick brown fox jumps over the lazy dog");
|
||||
case 12:// char
|
||||
case 15:// nchar
|
||||
return ("The quick brown fox jumps over the lazy dog");
|
||||
|
||||
case 13:// varchar
|
||||
case 16:// nvarchar
|
||||
return ("The quick brown fox jumps over the lazy dog 9876543210");
|
||||
case 13:// varchar
|
||||
case 16:// nvarchar
|
||||
return ("The quick brown fox jumps over the lazy dog 9876543210");
|
||||
|
||||
case 14:// varchar(max)
|
||||
case 17:// nvarchar(max)
|
||||
return ("The quick brown fox jumps over the lazy dog 0123456789");
|
||||
case 14:// varchar(max)
|
||||
case 17:// nvarchar(max)
|
||||
return ("The quick brown fox jumps over the lazy dog 0123456789");
|
||||
|
||||
case 18:// text
|
||||
case 19:// ntext
|
||||
return ("0123456789 The quick brown fox jumps over the lazy dog");
|
||||
case 18:// text
|
||||
case 19:// ntext
|
||||
return ("0123456789 The quick brown fox jumps over the lazy dog");
|
||||
|
||||
case 20:// binary
|
||||
return ("0123456789");
|
||||
case 20:// binary
|
||||
return ("0123456789");
|
||||
|
||||
case 21:// varbinary
|
||||
return ("01234567899876543210");
|
||||
case 21:// varbinary
|
||||
return ("01234567899876543210");
|
||||
|
||||
case 22:// varbinary(max)
|
||||
return ("98765432100123456789");
|
||||
case 22:// varbinary(max)
|
||||
return ("98765432100123456789");
|
||||
|
||||
case 23:// image
|
||||
return ("01234567899876543210");
|
||||
case 23:// image
|
||||
return ("01234567899876543210");
|
||||
|
||||
case 24:// uniqueidentifier
|
||||
return ("12345678-9012-3456-7890-123456789012");
|
||||
case 24:// uniqueidentifier
|
||||
return ("12345678-9012-3456-7890-123456789012");
|
||||
|
||||
case 25:// datetime
|
||||
case 26:// smalldatetime
|
||||
return (date("Y-m-d"));
|
||||
case 25:// datetime
|
||||
case 26:// smalldatetime
|
||||
return (date("Y-m-d"));
|
||||
|
||||
case 27:// timestamp
|
||||
return (null);
|
||||
case 27:// timestamp
|
||||
return (null);
|
||||
|
||||
case 28:// xml
|
||||
return ("<XmlTestData><Letters1>The quick brown fox jumps over the lazy dog</Letters1><Digits1>0123456789</Digits1></XmlTestData>");
|
||||
case 28:// xml
|
||||
return ("<XmlTestData><Letters1>The quick brown fox jumps over the lazy dog</Letters1><Digits1>0123456789</Digits1></XmlTestData>");
|
||||
|
||||
default:
|
||||
break;
|
||||
}
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
return (null);
|
||||
return (null);
|
||||
}
|
||||
|
||||
|
||||
function CreateDB($conn, $dbName)
|
||||
{
|
||||
Trace("Creating database $dbName ...");
|
||||
$tsql = "CREATE DATABASE [$dbName]";
|
||||
DropDB($conn, $dbName);
|
||||
Trace("Creating database $dbName ...");
|
||||
$tsql = "CREATE DATABASE [$dbName]";
|
||||
DropDB($conn, $dbName);
|
||||
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($tsql);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create test database: $dbName");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create test database: $dbName");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($tsql);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create test database: $dbName");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create test database: $dbName");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
}
|
||||
|
||||
function DropDB($conn, $dbName)
|
||||
{
|
||||
$tsql = "DROP DATABASE [$dbName]";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$mode = $conn->getAttribute(PDO::ATTR_ERRMODE);
|
||||
$tsql = "DROP DATABASE [$dbName]";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$mode = $conn->getAttribute(PDO::ATTR_ERRMODE);
|
||||
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
|
||||
|
||||
$outcome = $conn->exec($tsql);
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, $mode);
|
||||
$outcome = $conn->exec($tsql);
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, $mode);
|
||||
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function CreateTable($conn, $tableName)
|
||||
{
|
||||
$dataType = "[c1_int] int, [c2_tinyint] tinyint, [c3_smallint] smallint, [c4_bigint] bigint, [c5_bit] bit, [c6_float] float, [c7_real] real, [c8_decimal] decimal(28,4), [c9_numeric] numeric(32,4), [c10_money] money, [c11_smallmoney] smallmoney, [c12_char] char(512), [c13_varchar] varchar(512), [c14_varchar_max] varchar(max), [c15_nchar] nchar(512), [c16_nvarchar] nvarchar(512), [c17_nvarchar_max] nvarchar(max), [c18_text] text, [c19_ntext] ntext, [c20_binary] binary(512), [c21_varbinary] varbinary(512), [c22_varbinary_max] varbinary(max), [c23_image] image, [c24_uniqueidentifier] uniqueidentifier, [c25_datetime] datetime, [c26_smalldatetime] smalldatetime, [c27_timestamp] timestamp, [c28_xml] xml";
|
||||
CreateTableEx($conn, $tableName, $dataType);
|
||||
if (IsDaasMode())
|
||||
{
|
||||
$colIndex = "[c1_int], [c2_tinyint], [c3_smallint], [c4_bigint], [c5_bit], [c6_float], [c7_real], [c8_decimal], [c9_numeric]";
|
||||
CreateTableIndex($conn, $tableName, $colIndex);
|
||||
}
|
||||
$dataType = "[c1_int] int, [c2_tinyint] tinyint, [c3_smallint] smallint, [c4_bigint] bigint, [c5_bit] bit, [c6_float] float, [c7_real] real, [c8_decimal] decimal(28,4), [c9_numeric] numeric(32,4), [c10_money] money, [c11_smallmoney] smallmoney, [c12_char] char(512), [c13_varchar] varchar(512), [c14_varchar_max] varchar(max), [c15_nchar] nchar(512), [c16_nvarchar] nvarchar(512), [c17_nvarchar_max] nvarchar(max), [c18_text] text, [c19_ntext] ntext, [c20_binary] binary(512), [c21_varbinary] varbinary(512), [c22_varbinary_max] varbinary(max), [c23_image] image, [c24_uniqueidentifier] uniqueidentifier, [c25_datetime] datetime, [c26_smalldatetime] smalldatetime, [c27_timestamp] timestamp, [c28_xml] xml";
|
||||
CreateTableEx($conn, $tableName, $dataType);
|
||||
if (IsDaasMode())
|
||||
{
|
||||
$colIndex = "[c1_int], [c2_tinyint], [c3_smallint], [c4_bigint], [c5_bit], [c6_float], [c7_real], [c8_decimal], [c9_numeric]";
|
||||
CreateTableIndex($conn, $tableName, $colIndex);
|
||||
}
|
||||
}
|
||||
|
||||
function CreateTableEx($conn, $tableName, $dataType)
|
||||
{
|
||||
Trace("Creating table $tableName ...");
|
||||
$tsql = "CREATE TABLE [$tableName] ($dataType)";
|
||||
DropTable($conn,$tableName);
|
||||
Trace("Creating table $tableName ...");
|
||||
$tsql = "CREATE TABLE [$tableName] ($dataType)";
|
||||
DropTable($conn,$tableName);
|
||||
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($tsql);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create test table: $tsql");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create test table: $tsql");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($tsql);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create test table: $tsql");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create test table: $tsql");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
}
|
||||
|
||||
|
||||
function CreateTableIndex($conn, $tableName, $colIndex)
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
CreateTableIndexEx($conn, $tableName, $tableIndex, $colIndex);
|
||||
require 'MsSetup.inc';
|
||||
CreateTableIndexEx($conn, $tableName, $tableIndex, $colIndex);
|
||||
}
|
||||
|
||||
|
||||
function CreateTableIndexEx($conn, $tableName, $tableIndex, $colIndex)
|
||||
{
|
||||
Trace("Creating table index for $tableName ...");
|
||||
$sqlIndex = "CREATE CLUSTERED INDEX [$tableIndex] ON [$tableName]($colIndex)";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($sqlIndex);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create clustered index for test table: $sqlIndex");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $sqlIndex);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create clustered index for test table: $sqlIndex");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
Trace("Creating table index for $tableName ...");
|
||||
$sqlIndex = "CREATE CLUSTERED INDEX [$tableIndex] ON [$tableName]($colIndex)";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($sqlIndex);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create clustered index for test table: $sqlIndex");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $sqlIndex);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create clustered index for test table: $sqlIndex");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
}
|
||||
|
||||
function CreateUniqueIndex($conn, $tableName, $colIndex)
|
||||
{
|
||||
require 'MsSetup.inc';
|
||||
CreateUniqueIndexEx($conn, $tableName, $tableIndex, $colIndex);
|
||||
require 'MsSetup.inc';
|
||||
CreateUniqueIndexEx($conn, $tableName, $tableIndex, $colIndex);
|
||||
}
|
||||
|
||||
function CreateUniqueIndexEx($conn, $tableName, $tableIndex, $colIndex)
|
||||
{
|
||||
Trace("Creating unique table index for $tableName ...");
|
||||
$sqlIndex = "CREATE UNIQUE INDEX [$tableIndex] ON [$tableName]($colIndex)";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($sqlIndex);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create unique index for test table: $sqlIndex");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $sqlIndex);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create unique index for test table: $sqlIndex");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
Trace("Creating unique table index for $tableName ...");
|
||||
$sqlIndex = "CREATE UNIQUE INDEX [$tableIndex] ON [$tableName]($colIndex)";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$outcome = $conn->exec($sqlIndex);
|
||||
if ($outcome === false)
|
||||
{
|
||||
FatalError("Failed to create unique index for test table: $sqlIndex");
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $sqlIndex);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create unique index for test table: $sqlIndex");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
}
|
||||
|
||||
function DropTable($conn, $tableName)
|
||||
{
|
||||
$tsql = "DROP TABLE [$tableName]";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$mode = $conn->getAttribute(PDO::ATTR_ERRMODE);
|
||||
$tsql = "DROP TABLE [$tableName]";
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$mode = $conn->getAttribute(PDO::ATTR_ERRMODE);
|
||||
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_SILENT);
|
||||
|
||||
$outcome = $conn->exec($tsql);
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, $mode);
|
||||
$outcome = $conn->exec($tsql);
|
||||
$conn->setAttribute(PDO::ATTR_ERRMODE, $mode);
|
||||
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
if ($stmt === false)
|
||||
{
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function SelectFromTable($conn, $tableName)
|
||||
{
|
||||
return (SelectFromTableEx($conn, $tableName, null));
|
||||
return (SelectFromTableEx($conn, $tableName, null));
|
||||
}
|
||||
|
||||
function SelectFromTableEx($conn, $tableName, $cond)
|
||||
{
|
||||
if (($cond != null) && (strlen($cond) > 0))
|
||||
{
|
||||
return (SelectQuery($conn, "SELECT * FROM [$tableName] WHERE $cond"));
|
||||
}
|
||||
else
|
||||
{
|
||||
return (SelectQuery($conn, "SELECT * FROM [$tableName]"));
|
||||
}
|
||||
if (($cond != null) && (strlen($cond) > 0))
|
||||
{
|
||||
return (SelectQuery($conn, "SELECT * FROM [$tableName] WHERE $cond"));
|
||||
}
|
||||
else
|
||||
{
|
||||
return (SelectQuery($conn, "SELECT * FROM [$tableName]"));
|
||||
}
|
||||
}
|
||||
|
||||
function SelectQuery($conn, $query)
|
||||
{
|
||||
return (SelectQueryEx($conn, $query, null));
|
||||
return (SelectQueryEx($conn, $query, null));
|
||||
}
|
||||
|
||||
function SelectQueryEx($conn, $query, $options)
|
||||
{
|
||||
$numFields = 0;
|
||||
if (IsPDOMode())
|
||||
{
|
||||
$stmt = ExecuteQuery($conn, $query);
|
||||
$numFields = $stmt->columnCount();
|
||||
}
|
||||
else
|
||||
{
|
||||
if ($options != null)
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $query, null, $options);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $query);
|
||||
}
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to query test table");
|
||||
}
|
||||
$numFields = 0;
|
||||
if (IsPDOMode())
|
||||
{
|
||||
$stmt = ExecuteQuery($conn, $query);
|
||||
$numFields = $stmt->columnCount();
|
||||
}
|
||||
else
|
||||
{
|
||||
if ($options != null)
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $query, null, $options);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $query);
|
||||
}
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to query test table");
|
||||
}
|
||||
|
||||
$numFields = sqlsrv_num_fields($stmt);
|
||||
}
|
||||
if ($numFields <= 0)
|
||||
{
|
||||
die("Unexpected number of fields: .$numFields");
|
||||
}
|
||||
return ($stmt);
|
||||
$numFields = sqlsrv_num_fields($stmt);
|
||||
}
|
||||
if ($numFields <= 0)
|
||||
{
|
||||
die("Unexpected number of fields: .$numFields");
|
||||
}
|
||||
return ($stmt);
|
||||
}
|
||||
|
||||
function RowCount($stmt)
|
||||
{
|
||||
$rowCount = 0;
|
||||
if (IsPdoMode())
|
||||
{
|
||||
while ($stmt->fetchColumn())
|
||||
{
|
||||
$rowCount++;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
while (sqlsrv_fetch($stmt))
|
||||
{
|
||||
$rowCount++;
|
||||
}
|
||||
}
|
||||
return ($rowCount);
|
||||
$rowCount = 0;
|
||||
if (IsPdoMode())
|
||||
{
|
||||
while ($stmt->fetchColumn())
|
||||
{
|
||||
$rowCount++;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
while (sqlsrv_fetch($stmt))
|
||||
{
|
||||
$rowCount++;
|
||||
}
|
||||
}
|
||||
return ($rowCount);
|
||||
}
|
||||
|
||||
|
||||
function NumRows($conn, $tableName)
|
||||
{
|
||||
$stmt = SelectFromTable($conn, $tableName);
|
||||
$rowCount = RowCount($stmt);
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = null;
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
$stmt = SelectFromTable($conn, $tableName);
|
||||
$rowCount = RowCount($stmt);
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = null;
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
|
||||
return ($rowCount);
|
||||
return ($rowCount);
|
||||
}
|
||||
|
||||
|
||||
|
|
@ -1171,325 +1207,325 @@ function InsertQuery($tableName)
|
|||
|
||||
function InsertRows($conn, $tableName, $rowCount)
|
||||
{
|
||||
Trace("Inserting $rowCount rows into $tableName ...");
|
||||
$count = 0;
|
||||
for($i = 0; $i < $rowCount; $i++)
|
||||
{
|
||||
if (InsertRow($conn, $tableName))
|
||||
{
|
||||
$count++;
|
||||
}
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
if ($count != $rowCount)
|
||||
{
|
||||
die("$count rows inserted instead of $rowCount\n");
|
||||
}
|
||||
return ($count);
|
||||
Trace("Inserting $rowCount rows into $tableName ...");
|
||||
$count = 0;
|
||||
for($i = 0; $i < $rowCount; $i++)
|
||||
{
|
||||
if (InsertRow($conn, $tableName))
|
||||
{
|
||||
$count++;
|
||||
}
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
if ($count != $rowCount)
|
||||
{
|
||||
die("$count rows inserted instead of $rowCount\n");
|
||||
}
|
||||
return ($count);
|
||||
}
|
||||
|
||||
function InsertRowsByRange($conn, $tableName, $minIndex, $maxIndex)
|
||||
{
|
||||
$rowCount = $maxIndex - $minIndex + 1;
|
||||
if ($rowCount > 0)
|
||||
{
|
||||
Trace("Inserting $rowCount rows into $tableName ...");
|
||||
for($i = $minIndex; $i <= $maxIndex; $i++)
|
||||
{
|
||||
InsertRowByIndex($conn, $tableName, $i);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
}
|
||||
$rowCount = $maxIndex - $minIndex + 1;
|
||||
if ($rowCount > 0)
|
||||
{
|
||||
Trace("Inserting $rowCount rows into $tableName ...");
|
||||
for($i = $minIndex; $i <= $maxIndex; $i++)
|
||||
{
|
||||
InsertRowByIndex($conn, $tableName, $i);
|
||||
}
|
||||
Trace(" completed successfully.\n");
|
||||
}
|
||||
}
|
||||
|
||||
function InsertRow($conn, $tableName)
|
||||
{
|
||||
$tsql = InsertQuery($tableName);
|
||||
$stmt = null;
|
||||
$tsql = InsertQuery($tableName);
|
||||
$stmt = null;
|
||||
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
}
|
||||
return (InsertCheck($stmt));
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
}
|
||||
return (InsertCheck($stmt));
|
||||
}
|
||||
|
||||
function InsertRowEx($conn, $tableName, $dataCols, $dataValues, $dataOptions)
|
||||
{
|
||||
$tsql = "INSERT INTO [$tableName] ($dataCols) VALUES ($dataValues)";
|
||||
$stmt = null;
|
||||
$tsql = "INSERT INTO [$tableName] ($dataCols) VALUES ($dataValues)";
|
||||
$stmt = null;
|
||||
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql, $dataOptions);
|
||||
}
|
||||
return (InsertCheck($stmt));
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql, $dataOptions);
|
||||
}
|
||||
return (InsertCheck($stmt));
|
||||
}
|
||||
|
||||
function InsertRowByIndex($conn, $tableName, $index)
|
||||
{
|
||||
$tsql = InsertQueryEx($tableName, $index);
|
||||
$stmt = null;
|
||||
$tsql = InsertQueryEx($tableName, $index);
|
||||
$stmt = null;
|
||||
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
}
|
||||
return (InsertCheck($stmt));
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql);
|
||||
}
|
||||
return (InsertCheck($stmt));
|
||||
}
|
||||
|
||||
function InsertStream($conn, $tableName, $dataCols, $dataValues, $dataOptions, $atExec)
|
||||
{
|
||||
$tsql = "INSERT INTO [$tableName] ($dataCols) VALUES ($dataValues)";
|
||||
$stmt = null;
|
||||
$tsql = "INSERT INTO [$tableName] ($dataCols) VALUES ($dataValues)";
|
||||
$stmt = null;
|
||||
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
if ($atExec)
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql, $dataOptions, array('SendStreamParamsAtExec' => 1));
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql, $dataOptions);
|
||||
if ($stmt)
|
||||
{
|
||||
while (sqlsrv_send_stream_data($stmt))
|
||||
{
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$stmt = $conn->exec($tsql);
|
||||
}
|
||||
else
|
||||
{
|
||||
if ($atExec)
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql, $dataOptions, array('SendStreamParamsAtExec' => 1));
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, $tsql, $dataOptions);
|
||||
if ($stmt)
|
||||
{
|
||||
while (sqlsrv_send_stream_data($stmt))
|
||||
{
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return (InsertCheck($stmt));
|
||||
return (InsertCheck($stmt));
|
||||
}
|
||||
|
||||
|
||||
function InsertCheck($stmt)
|
||||
{
|
||||
$numRows = 0;
|
||||
$numRows = 0;
|
||||
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to insert row into test table");
|
||||
}
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$numRows = $stmt;
|
||||
}
|
||||
else
|
||||
{
|
||||
$numRows = sqlsrv_rows_affected($stmt);
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
if ($numRows != 1)
|
||||
{
|
||||
die("Unexpected row count at insert: ".$numRows);
|
||||
}
|
||||
return (true);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to insert row into test table");
|
||||
}
|
||||
if (IsPdoMode())
|
||||
{
|
||||
$numRows = $stmt;
|
||||
}
|
||||
else
|
||||
{
|
||||
$numRows = sqlsrv_rows_affected($stmt);
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
if ($numRows != 1)
|
||||
{
|
||||
die("Unexpected row count at insert: ".$numRows);
|
||||
}
|
||||
return (true);
|
||||
}
|
||||
|
||||
function GetInsertData($rowIndex, $colIndex, $skip)
|
||||
{
|
||||
$query = InsertQueryEx("TestTable", $rowIndex);
|
||||
$data = strstr($query, "((");
|
||||
$pos = 1;
|
||||
if ($data === false)
|
||||
{
|
||||
die("Failed to retrieve data on row $rowIndex");
|
||||
}
|
||||
$data = substr($data, 2);
|
||||
$query = InsertQueryEx("TestTable", $rowIndex);
|
||||
$data = strstr($query, "((");
|
||||
$pos = 1;
|
||||
if ($data === false)
|
||||
{
|
||||
die("Failed to retrieve data on row $rowIndex");
|
||||
}
|
||||
$data = substr($data, 2);
|
||||
|
||||
while ($pos < ($colIndex - $skip))
|
||||
{
|
||||
$data = strstr($data, ", (");
|
||||
$pos++;
|
||||
if ($data === false)
|
||||
{
|
||||
die("Failed to retrieve data on row $rowIndex, column $pos");
|
||||
}
|
||||
$data = substr($data, 3);
|
||||
}
|
||||
$pos = strpos($data, ")");
|
||||
if ($pos === false)
|
||||
{
|
||||
die("Failed to isolate data on row $rowIndex, column $pos");
|
||||
}
|
||||
$data = substr($data, 0, $pos);
|
||||
if (strcasecmp($data, "null") == 0)
|
||||
{
|
||||
$data = "";
|
||||
}
|
||||
if (IsUnicode($colIndex))
|
||||
{ // N'data'
|
||||
$data = substr($data, 2, strlen($data) - 3);
|
||||
}
|
||||
else if (IsLiteral($colIndex))
|
||||
{ // 'data'
|
||||
$data = substr($data, 1, strlen($data) - 2);
|
||||
}
|
||||
else if (IsBinary($colIndex))
|
||||
{ // 0xdata
|
||||
$data = substr($data, 2);
|
||||
}
|
||||
return (trim($data));
|
||||
while ($pos < ($colIndex - $skip))
|
||||
{
|
||||
$data = strstr($data, ", (");
|
||||
$pos++;
|
||||
if ($data === false)
|
||||
{
|
||||
die("Failed to retrieve data on row $rowIndex, column $pos");
|
||||
}
|
||||
$data = substr($data, 3);
|
||||
}
|
||||
$pos = strpos($data, ")");
|
||||
if ($pos === false)
|
||||
{
|
||||
die("Failed to isolate data on row $rowIndex, column $pos");
|
||||
}
|
||||
$data = substr($data, 0, $pos);
|
||||
if (strcasecmp($data, "null") == 0)
|
||||
{
|
||||
$data = "";
|
||||
}
|
||||
if (IsUnicode($colIndex))
|
||||
{ // N'data'
|
||||
$data = substr($data, 2, strlen($data) - 3);
|
||||
}
|
||||
else if (IsLiteral($colIndex))
|
||||
{ // 'data'
|
||||
$data = substr($data, 1, strlen($data) - 2);
|
||||
}
|
||||
else if (IsBinary($colIndex))
|
||||
{ // 0xdata
|
||||
$data = substr($data, 2);
|
||||
}
|
||||
return (trim($data));
|
||||
}
|
||||
|
||||
function CreateProc($conn, $procName, $procArgs, $procCode)
|
||||
{
|
||||
DropProc($conn,$procName);
|
||||
DropProc($conn,$procName);
|
||||
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, "CREATE PROC [$procName] ($procArgs) AS BEGIN $procCode END");
|
||||
if ($stmt === false)
|
||||
FatalError("Failed to create test procedure");
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = $conn->query("CREATE PROC [$procName] ($procArgs) AS BEGIN $procCode END");
|
||||
}
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, "CREATE PROC [$procName] ($procArgs) AS BEGIN $procCode END");
|
||||
if ($stmt === false)
|
||||
FatalError("Failed to create test procedure");
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
else
|
||||
{
|
||||
$stmt = $conn->query("CREATE PROC [$procName] ($procArgs) AS BEGIN $procCode END");
|
||||
}
|
||||
}
|
||||
|
||||
function DropProc($conn, $procName)
|
||||
{
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, "DROP PROC [$procName]");
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
else
|
||||
{
|
||||
|
||||
$query = "IF OBJECT_ID('[$procName]', 'P') IS NOT NULL DROP PROCEDURE [$procName]";
|
||||
$stmt = $conn->query($query);
|
||||
}
|
||||
if (!IsPdoMode())
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, "DROP PROC [$procName]");
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
else
|
||||
{
|
||||
|
||||
$query = "IF OBJECT_ID('[$procName]', 'P') IS NOT NULL DROP PROCEDURE [$procName]";
|
||||
$stmt = $conn->query($query);
|
||||
}
|
||||
}
|
||||
|
||||
function CallProc($conn, $procName, $procArgs, $procValues)
|
||||
{
|
||||
$stmt = CallProcEx($conn, $procName, "", $procArgs, $procValues);
|
||||
sqlsrv_free_stmt($stmt);
|
||||
$stmt = CallProcEx($conn, $procName, "", $procArgs, $procValues);
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
|
||||
function CallProcEx($conn, $procName, $procPrefix, $procArgs, $procValues)
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, "{ $procPrefix CALL [$procName] ($procArgs)}", $procValues);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to call test procedure");
|
||||
}
|
||||
return ($stmt);
|
||||
$stmt = sqlsrv_query($conn, "{ $procPrefix CALL [$procName] ($procArgs)}", $procValues);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to call test procedure");
|
||||
}
|
||||
return ($stmt);
|
||||
}
|
||||
|
||||
|
||||
function CreateFunc($conn, $funcName, $funcArgs, $retType, $funcCode)
|
||||
{
|
||||
DropFunc($conn,$funcName);
|
||||
$stmt = sqlsrv_query($conn, "CREATE FUNCTION [$funcName] ($funcArgs) RETURNS $retType AS BEGIN $funcCode END");
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create test function");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
DropFunc($conn,$funcName);
|
||||
$stmt = sqlsrv_query($conn, "CREATE FUNCTION [$funcName] ($funcArgs) RETURNS $retType AS BEGIN $funcCode END");
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to create test function");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
|
||||
function DropFunc($conn, $funcName)
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, "DROP FUNCTION [$funcName]");
|
||||
if ($stmt === false)
|
||||
{
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
$stmt = sqlsrv_query($conn, "DROP FUNCTION [$funcName]");
|
||||
if ($stmt === false)
|
||||
{
|
||||
}
|
||||
else
|
||||
{
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function CallFunc($conn, $funcName, $funcArgs, $funcValues)
|
||||
{
|
||||
$stmt = sqlsrv_query($conn, "{ ? = CALL [$funcName]($funcArgs)}", $funcValues);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to call test function");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
$stmt = sqlsrv_query($conn, "{ ? = CALL [$funcName]($funcArgs)}", $funcValues);
|
||||
if ($stmt === false)
|
||||
{
|
||||
FatalError("Failed to call test function");
|
||||
}
|
||||
sqlsrv_free_stmt($stmt);
|
||||
}
|
||||
|
||||
function handle_errors()
|
||||
{
|
||||
$errors = sqlsrv_errors(SQLSRV_ERR_ERRORS);
|
||||
$count = count($errors);
|
||||
if($count == 0)
|
||||
{
|
||||
$errors = sqlsrv_errors(SQLSRV_ERR_ALL);
|
||||
$count = count($errors);
|
||||
}
|
||||
if($count > 0)
|
||||
{
|
||||
for($i = 0; $i < $count; $i++)
|
||||
{
|
||||
Trace($errors[$i]['message']."\n");
|
||||
}
|
||||
}
|
||||
$errors = sqlsrv_errors(SQLSRV_ERR_ERRORS);
|
||||
$count = count($errors);
|
||||
if($count == 0)
|
||||
{
|
||||
$errors = sqlsrv_errors(SQLSRV_ERR_ALL);
|
||||
$count = count($errors);
|
||||
}
|
||||
if($count > 0)
|
||||
{
|
||||
for($i = 0; $i < $count; $i++)
|
||||
{
|
||||
Trace($errors[$i]['message']."\n");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function str2hex($dataIn)
|
||||
{
|
||||
$dataOut = "";
|
||||
$len = strlen($dataIn);
|
||||
for ($i = 0; $i < $len; $i++)
|
||||
{
|
||||
$ch = strtoupper(substr($dataIn, $i, 1));
|
||||
if ($ch == "A")
|
||||
{
|
||||
$dataOut = $dataOut."41";
|
||||
}
|
||||
else if ($ch == "B")
|
||||
{
|
||||
$dataOut = $dataOut."42";
|
||||
}
|
||||
else if ($ch == "C")
|
||||
{
|
||||
$dataOut = $dataOut."43";
|
||||
}
|
||||
else if ($ch == "D")
|
||||
{
|
||||
$dataOut = $dataOut."44";
|
||||
}
|
||||
else if ($ch == "E")
|
||||
{
|
||||
$dataOut = $dataOut."45";
|
||||
}
|
||||
else if ($ch == "F")
|
||||
{
|
||||
$dataOut = $dataOut."46";
|
||||
}
|
||||
else
|
||||
{
|
||||
$dataOut = $dataOut."3".$ch;
|
||||
}
|
||||
$dataOut = "";
|
||||
$len = strlen($dataIn);
|
||||
for ($i = 0; $i < $len; $i++)
|
||||
{
|
||||
$ch = strtoupper(substr($dataIn, $i, 1));
|
||||
if ($ch == "A")
|
||||
{
|
||||
$dataOut = $dataOut."41";
|
||||
}
|
||||
else if ($ch == "B")
|
||||
{
|
||||
$dataOut = $dataOut."42";
|
||||
}
|
||||
else if ($ch == "C")
|
||||
{
|
||||
$dataOut = $dataOut."43";
|
||||
}
|
||||
else if ($ch == "D")
|
||||
{
|
||||
$dataOut = $dataOut."44";
|
||||
}
|
||||
else if ($ch == "E")
|
||||
{
|
||||
$dataOut = $dataOut."45";
|
||||
}
|
||||
else if ($ch == "F")
|
||||
{
|
||||
$dataOut = $dataOut."46";
|
||||
}
|
||||
else
|
||||
{
|
||||
$dataOut = $dataOut."3".$ch;
|
||||
}
|
||||
|
||||
}
|
||||
return ($dataOut);
|
||||
}
|
||||
return ($dataOut);
|
||||
}
|
||||
|
||||
function PhpVersionComponents( &$major, &$minor, &$sub )
|
||||
|
|
|
|||
Loading…
Reference in a new issue