dprevot/php-sqlsrv
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Modified test_largeData for Linux CI (#954)

Browse source
This commit is contained in:
Jenny Tam 2019-03-18 08:46:20 -07:00 committed by GitHub
parent 15f61bd0b4
commit 7f56eab86e
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 98 additions and 59 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

157
test/functional/sqlsrv/test_largeData.phpt
View file

@ -1,119 +1,158 @@
--TEST-- --TEST--
send a large amount (10MB) using encryption. Send a large amount (10MB) using encryption. In a Linux CI environment use a smaller size.
--SKIPIF-- --SKIPIF--
<?php require('skipif_azure_dw.inc'); ?> <?php require('skipif_azure_dw.inc'); ?>
--FILE-- --FILE--
<?php <?php
class my_stream { class my_stream
{
var $total_read = 0; public $total_read = 0;
function stream_open ($path, $mode, $options, &$opened_path ) public function stream_open($path, $mode, $options, &$opened_path)
{ {
$this->total_read = 0; $this->total_read = 0;
return true; return true;
} }
function stream_read( $count ) public function stream_read($count)
{ {
if( $this->total_read > 20000000 ) { global $limit;
if ($this->total_read > $limit) {
return 0; return 0;
} }
global $packets; global $packets;
++$packets; ++$packets;
$str = str_repeat( "A", $count );
// 8192 is passed to stream_read as $count
$str = str_repeat("A", $count);
$this->total_read += $count; $this->total_read += $count;
return $str; return $str;
} }
function stream_write($data) public function stream_write($data)
{ {
} }
function stream_tell() public function stream_tell()
{ {
return $this->total_read; return $this->total_read;
} }
function stream_eof() public function stream_eof()
{ {
return $this->total_read > 20000000; global $limit;
return $this->total_read > $limit;
} }
function stream_seek($offset, $whence) public function stream_seek($offset, $whence)
{ {
// For the purpose of this test only support SEEK_SET to $offset 0 // For the purpose of this test only support SEEK_SET to $offset 0
if ($whence == SEEK_SET && $offset == 0) { if ($whence == SEEK_SET && $offset == 0) {
$this->total_read = $offset; $this->total_read = $offset;
return true; return true;
} }
return false; return false;
} }
} }
function isServerInLinux($conn)
{
// This checks if SQL Server is running in Linux (Docker) in a CI environment
// If so, the major version must be 14 or above (SQL Server 2017 or above)
$serverVer = sqlsrv_server_info($conn)['SQLServerVersion'];
if (explode('.', $serverVer)[0] < 14) {
return false;
}
// The view sys.dm_os_host_info, available starting in SQL Server 2017, is somewhat similar to sys.dm_os_windows_info.
// It returns one row that displays operating system version information and has columns to differentiate
// Windows and Linux.
$stmt = sqlsrv_query($conn, 'SELECT host_platform FROM sys.dm_os_host_info');
if ($stmt && sqlsrv_fetch($stmt)) {
$host = sqlsrv_get_field($stmt, 0);
return ($host === 'Linux');
}
return false;
}
set_time_limit(0); set_time_limit(0);
sqlsrv_configure( 'WarningsReturnAsErrors', 0 ); sqlsrv_configure('WarningsReturnAsErrors', 0);
sqlsrv_configure( 'LogSubsystems', SQLSRV_LOG_SYSTEM_ALL ); sqlsrv_configure('LogSubsystems', SQLSRV_LOG_SYSTEM_ALL);
$packets = 0; $packets = 0;
$limit = 20000000;
$result = stream_wrapper_register( "mystr", "my_stream" ); $result = stream_wrapper_register("mystr", "my_stream");
if( !$result ) { if (!$result) {
die( "Couldn't register stream class." ); die("Couldn't register stream class.");
} }
require( 'MsCommon.inc' ); require_once('MsCommon.inc');
$conn = Connect(array( 'Encrypt' => true, 'TrustServerCertificate' => true )); $conn = Connect(array( 'Encrypt' => true, 'TrustServerCertificate' => true ));
if( $conn === false ) { if ($conn === false) {
die( print_r( sqlsrv_errors(), true )); die(print_r(sqlsrv_errors(), true));
} }
$stmt = sqlsrv_query( $conn, "IF OBJECT_ID('test_lob', 'U') IS NOT NULL DROP TABLE test_lob" ); // In a Linux CI environment use a smaller size
if( $stmt !== false ) sqlsrv_free_stmt( $stmt ); if (isServerInLinux($conn)) {
$limit /= 100;
$stmt = sqlsrv_query( $conn, "CREATE TABLE test_lob (id tinyint, stuff varbinary(max))" );
if( $stmt === false ) {
die( print_r( sqlsrv_errors(), true ));
}
sqlsrv_free_stmt( $stmt );
$lob = fopen( "mystr://test_data", "rb" );
if( !$lob ) {
die( "failed opening test stream.\n" );
}
$stmt = sqlsrv_query( $conn, "INSERT INTO test_lob (id, stuff) VALUES (?,?)", array( 1, array( $lob, SQLSRV_PARAM_IN, SQLSRV_PHPTYPE_STREAM(SQLSRV_ENC_BINARY), SQLSRV_SQLTYPE_VARBINARY('max'))));
if( $stmt === false ) {
die( print_r( sqlsrv_errors(), true ));
} }
while( $result = sqlsrv_send_stream_data( $stmt )) { $stmt = sqlsrv_query($conn, "IF OBJECT_ID('test_lob', 'U') IS NOT NULL DROP TABLE test_lob");
if ($stmt !== false) {
sqlsrv_free_stmt($stmt);
}
$stmt = sqlsrv_query($conn, "CREATE TABLE test_lob (id tinyint, stuff varbinary(max))");
if ($stmt === false) {
die(print_r(sqlsrv_errors(), true));
}
sqlsrv_free_stmt($stmt);
$lob = fopen("mystr://test_data", "rb");
if (!$lob) {
die("failed opening test stream.\n");
}
$stmt = sqlsrv_query($conn, "INSERT INTO test_lob (id, stuff) VALUES (?,?)", array( 1, array( $lob, SQLSRV_PARAM_IN, SQLSRV_PHPTYPE_STREAM(SQLSRV_ENC_BINARY), SQLSRV_SQLTYPE_VARBINARY('max'))));
if ($stmt === false) {
die(print_r(sqlsrv_errors(), true));
}
while ($result = sqlsrv_send_stream_data($stmt)) {
++$packets; ++$packets;
} }
if( $result === false ) { if ($result === false) {
die( print_r( sqlsrv_errors(), true )); die(print_r(sqlsrv_errors(), true));
}
echo "$packets sent.\n";
$stmt = sqlsrv_query( $conn, "SELECT LEN(stuff) FROM test_lob" );
if( $stmt === false ) {
die( print_r( sqlsrv_errors(), true ));
}
while( $result = sqlsrv_fetch_array( $stmt )) {
print_r( $result );
} }
sqlsrv_query( $conn, "DROP TABLE test_lob" ); // Number of packets sent should be $limit / 8192 (rounded up)
// Length of the varbinary = $packetsSent * 8192 + 1 (HEX 30 appended at the end)
$packetsSent = ceil($limit / 8192);
$length = $packetsSent * 8192 + 1;
if ($packets != $packetsSent) {
echo "$packets sent.\n";
}
sqlsrv_free_stmt( $stmt ); $stmt = sqlsrv_query($conn, "SELECT LEN(stuff) FROM test_lob");
sqlsrv_close( $conn ); if ($stmt === false) {
die(print_r(sqlsrv_errors(), true));
}
while ($result = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_NUMERIC)) {
if ($result[0] != $length) {
print_r($result);
}
}
sqlsrv_query($conn, "DROP TABLE test_lob");
sqlsrv_free_stmt($stmt);
sqlsrv_close($conn);
sleep(10); // since this is a long test, we give the database some time to finish sleep(10); // since this is a long test, we give the database some time to finish
echo "Done\n";
?> ?>
--EXPECT-- --EXPECT--
2442 sent. Done
Array
(
[0] => 20004865
[] => 20004865
)