Quella/MySql
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

init

Browse Source
This commit is contained in:
Quella
2025-09-07 16:09:16 +08:00
commit 9c0327fc48
134 changed files with 4914 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
Navicat/Navicat Premium 16/resource/charts/Sample.nchartsdemo Normal file
View File

Binary file not shown.

BIN
Navicat/Navicat Premium 16/resource/charts/Sample.xlsx Normal file
View File

Binary file not shown.

BIN
Navicat/Navicat Premium 16/resource/datagen/datagen_sample.db Normal file
View File

Binary file not shown.

558
Navicat/Navicat Premium 16/resource/httptunnel/ntunnel_mysql.php Normal file
View File

@@ -0,0 +1,558 @@
<?php
$versionNum = 206; // remark: require update CC_HTTP_TUNNEL_SCRIPT_LATEST_VERSION_MYSQL
//set allowTestMenu to false to disable System/Server test page
$allowTestMenu = true;
$use_mysqli = function_exists("mysqli_connect");
header("Content-Type: text/plain; charset=x-user-defined");
error_reporting(0);
set_time_limit(0);
function phpversion_int()
{
list($maVer, $miVer, $edVer) = preg_split("(/|\.|-)", phpversion());
return $maVer*10000 + $miVer*100 + $edVer;
}
if (phpversion_int() < 50300)
{
set_magic_quotes_runtime(0);
}
function GetLongBinary($num)
{
return pack("N",$num);
}
function GetShortBinary($num)
{
return pack("n",$num);
}
function GetDummy($count)
{
$str = "";
for($i=0;$i<$count;$i++)
$str .= "\x00";
return $str;
}
function GetBlock($val)
{
$len = strlen($val);
if( $len < 254 )
return chr($len).$val;
else
return "\xFE".GetLongBinary($len).$val;
}
function EchoHeader($errno)
{
global $versionNum;
$str = GetLongBinary(1111);
$str .= GetShortBinary($versionNum);
$str .= GetLongBinary($errno);
$str .= GetDummy(6);
echo $str;
}
function EchoConnInfo($conn)
{
if ($GLOBALS['use_mysqli']) {
$str = GetBlock(mysqli_get_host_info($conn));
$str .= GetBlock(mysqli_get_proto_info($conn));
$str .= GetBlock(mysqli_get_server_info($conn));
echo $str;
} else {
$str = GetBlock(mysql_get_host_info($conn));
$str .= GetBlock(mysql_get_proto_info($conn));
$str .= GetBlock(mysql_get_server_info($conn));
echo $str;
}
}
function EchoResultSetHeader($errno, $affectrows, $insertid, $numfields, $numrows)
{
$str = GetLongBinary($errno);
$str .= GetLongBinary($affectrows);
$str .= GetLongBinary($insertid);
$str .= GetLongBinary($numfields);
$str .= GetLongBinary($numrows);
$str .= GetDummy(12);
echo $str;
}
function EchoFieldsHeader($res, $numfields)
{
$str = "";
for( $i = 0; $i < $numfields; $i++ ) {
if ($GLOBALS['use_mysqli']) {
$finfo = mysqli_fetch_field_direct($res, $i);
$str .= GetBlock($finfo->name);
$str .= GetBlock($finfo->table);
$type = $finfo->type;
$length = $finfo->length;
$str .= GetLongBinary($type);
$intflag = $finfo->flags;
$str .= GetLongBinary($intflag);
$str .= GetLongBinary($length);
} else {
$str .= GetBlock(mysql_field_name($res, $i));
$str .= GetBlock(mysql_field_table($res, $i));
$type = mysql_field_type($res, $i);
$length = mysql_field_len($res, $i);
switch ($type) {
case "int":
if( $length > 11 ) $type = 8;
else $type = 3;
break;
case "real":
if( $length == 12 ) $type = 4;
elseif( $length == 22 ) $type = 5;
else $type = 0;
break;
case "null":
$type = 6;
break;
case "timestamp":
$type = 7;
break;
case "date":
$type = 10;
break;
case "time":
$type = 11;
break;
case "datetime":
$type = 12;
break;
case "year":
$type = 13;
break;
case "blob":
if( $length > 16777215 ) $type = 251;
elseif( $length > 65535 ) $type = 250;
elseif( $length > 255 ) $type = 252;
else $type = 249;
break;
default:
$type = 253;
}
$str .= GetLongBinary($type);
$flags = explode( " ", mysql_field_flags ( $res, $i ) );
$intflag = 0;
if(in_array( "not_null", $flags )) $intflag += 1;
if(in_array( "primary_key", $flags )) $intflag += 2;
if(in_array( "unique_key", $flags )) $intflag += 4;
if(in_array( "multiple_key", $flags )) $intflag += 8;
if(in_array( "blob", $flags )) $intflag += 16;
if(in_array( "unsigned", $flags )) $intflag += 32;
if(in_array( "zerofill", $flags )) $intflag += 64;
if(in_array( "binary", $flags)) $intflag += 128;
if(in_array( "enum", $flags )) $intflag += 256;
if(in_array( "auto_increment", $flags )) $intflag += 512;
if(in_array( "timestamp", $flags )) $intflag += 1024;
if(in_array( "set", $flags )) $intflag += 2048;
$str .= GetLongBinary($intflag);
$str .= GetLongBinary($length);
}
}
echo $str;
}
function EchoData($res, $numfields, $numrows)
{
for( $i = 0; $i < $numrows; $i++ ) {
$str = "";
$row = null;
if ($GLOBALS['use_mysqli'])
$row = mysqli_fetch_row( $res );
else
$row = mysql_fetch_row( $res );
for( $j = 0; $j < $numfields; $j++ ){
if( is_null($row[$j]) )
$str .= "\xFF";
else
$str .= GetBlock($row[$j]);
}
echo $str;
}
}
function doSystemTest()
{
global $versionNum;
function output($description, $succ, $resStr) {
echo "<tr><td class=\"TestDesc\">$description</td><td ";
echo ($succ)? "class=\"TestSucc\">$resStr[0]</td></tr>" : "class=\"TestFail\">$resStr[1]</td></tr>";
}
output("PHP version >= 4.0.5", phpversion_int() >= 40005, array("Yes (".phpversion().")", "No (".phpversion().")"));
output("mysql_connect() available", function_exists("mysql_connect"), array("Yes", "No"));
output("mysqli_connect() available", function_exists("mysqli_connect"), array("Yes", "No"));
if (phpversion_int() >= 40302 && substr($_SERVER["SERVER_SOFTWARE"], 0, 6) == "Apache" && function_exists("apache_get_modules")){
if (in_array("mod_security2", apache_get_modules()))
output("Mod Security 2 installed", false, array("No", "Yes"));
}
output("Current tunnel file version", true, array((int)($versionNum / 100) .".". ($versionNum % 100), ""));
}
/////////////////////////////////////////////////////////////////////////////
////
if (phpversion_int() < 40005) {
EchoHeader(201);
echo GetBlock("unsupported php version");
exit();
}
if (phpversion_int() < 40010) {
global $HTTP_POST_VARS;
$_POST = &$HTTP_POST_VARS;
}
if (!isset($_POST["actn"]) || !isset($_POST["host"]) || !isset($_POST["port"]) || !isset($_POST["login"])) {
$testMenu = $allowTestMenu;
if (!$testMenu){
EchoHeader(202);
echo GetBlock("invalid parameters");
exit();
}
}
if (!$testMenu){
if ($_POST["encodeBase64"] == '1') {
for($i=0;$i<count($_POST["q"]);$i++)
$_POST["q"][$i] = base64_decode($_POST["q"][$i]);
}
if (!function_exists("mysql_connect") && !function_exists("mysqli_connect")) {
EchoHeader(203);
echo GetBlock("MySQL not supported on the server");
exit();
}
$errno_c = 0;
$hs = $_POST["host"];
if ($use_mysqli) {
mysqli_report(MYSQLI_REPORT_OFF);
if( $_POST["port"] )
$conn = mysqli_connect($hs, $_POST["login"], $_POST["password"], '', $_POST["port"]);
else
$conn = mysqli_connect($hs, $_POST["login"], $_POST["password"]);
$errno_c = mysqli_connect_errno();
if($errno_c > 0) {
EchoHeader($errno_c);
echo GetBlock(mysqli_connect_error());
exit;
}
if (phpversion_int() >= 50005){ // for unicode database name
mysqli_set_charset($conn, 'UTF8');
}
if(($errno_c <= 0) && ( $_POST["db"] != "" )) {
$res = mysqli_select_db($conn, $_POST["db"] );
$errno_c = mysqli_errno($conn);
}
EchoHeader($errno_c);
if($errno_c > 0) {
echo GetBlock(mysqli_error($conn));
} elseif($_POST["actn"] == "C") {
EchoConnInfo($conn);
} elseif($_POST["actn"] == "Q") {
for($i=0;$i<count($_POST["q"]);$i++) {
$query = $_POST["q"][$i];
if($query == "") continue;
if (phpversion_int() < 50400){
if(get_magic_quotes_gpc())
$query = stripslashes($query);
}
mysqli_real_query($conn, $query);
$res = false;
if (mysqli_field_count($conn))
$res = mysqli_store_result($conn);
$errno = mysqli_errno($conn);
$affectedrows = mysqli_affected_rows($conn);
$insertid = mysqli_insert_id($conn);
if (false !== $res) {
$numfields = mysqli_field_count($conn);
$numrows = mysqli_num_rows($res);
}
else {
$numfields = 0;
$numrows = 0;
}
EchoResultSetHeader($errno, $affectedrows, $insertid, $numfields, $numrows);
if($errno > 0)
echo GetBlock(mysqli_error($conn));
else {
if($numfields > 0) {
EchoFieldsHeader($res, $numfields);
EchoData($res, $numfields, $numrows);
} else {
if(phpversion_int() >= 40300)
echo GetBlock(mysqli_info($conn));
else
echo GetBlock("");
}
}
if($i<(count($_POST["q"])-1))
echo "\x01";
else
echo "\x00";
if (false !== $res)
mysqli_free_result($res);
}
}
} else {
if( $_POST["port"] ) $hs .= ":".$_POST["port"];
$conn = mysql_connect($hs, $_POST["login"], $_POST["password"]);
$errno_c = mysql_errno();
if (phpversion_int() >= 50203){ // for unicode database name
mysql_set_charset('UTF8', $conn);
}
if(($errno_c <= 0) && ( $_POST["db"] != "" )) {
$res = mysql_select_db( $_POST["db"], $conn);
$errno_c = mysql_errno();
}
EchoHeader($errno_c);
if($errno_c > 0) {
echo GetBlock(mysql_error());
} elseif($_POST["actn"] == "C") {
EchoConnInfo($conn);
} elseif($_POST["actn"] == "Q") {
for($i=0;$i<count($_POST["q"]);$i++) {
$query = $_POST["q"][$i];
if($query == "") continue;
if (phpversion_int() < 50400){
if(get_magic_quotes_gpc())
$query = stripslashes($query);
}
$res = mysql_query($query, $conn);
$errno = mysql_errno();
$affectedrows = mysql_affected_rows($conn);
$insertid = mysql_insert_id($conn);
$numfields = mysql_num_fields($res);
$numrows = mysql_num_rows($res);
EchoResultSetHeader($errno, $affectedrows, $insertid, $numfields, $numrows);
if($errno > 0)
echo GetBlock(mysql_error());
else {
if($numfields > 0) {
EchoFieldsHeader($res, $numfields);
EchoData($res, $numfields, $numrows);
} else {
if(phpversion_int() >= 40300)
echo GetBlock(mysql_info($conn));
else
echo GetBlock("");
}
}
if($i<(count($_POST["q"])-1))
echo "\x01";
else
echo "\x00";
mysql_free_result($res);
}
}
}
exit();
}
header("Content-Type: text/html");
////
/////////////////////////////////////////////////////////////////////////////
?>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<title>Navicat HTTP Tunnel Tester</title>
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<style type="text/css">
body{
margin: 30px;
font-family: Tahoma;
font-weight: normal;
font-size: 14px;
color: #222222;
}
table{
width: 100%;
border: 0px;
}
input{
font-family:Tahoma,sans-serif;
border-style:solid;
border-color:#666666;
border-width:1px;
}
fieldset{
border-style:solid;
border-color:#666666;
border-width:1px;
}
.Title1{
font-size: 30px;
color: #003366;
}
.Title2{
font-size: 10px;
color: #999966;
}
.TestDesc{
width:70%
}
.TestSucc{
color: #00BB00;
}
.TestFail{
color: #DD0000;
}
.mysql{
}
.pgsql{
display:none;
}
.sqlite{
display:none;
}
#page{
max-width: 42em;
min-width: 36em;
border-width: 0px;
margin: auto auto;
}
#host, #dbfile{
width: 300px;
}
#port{
width: 75px;
}
#login, #password, #db{
width: 150px;
}
#Copyright{
text-align: right;
font-size: 10px;
color: #888888;
}
</style>
<script type="text/javascript">
function getInternetExplorerVersion(){
var ver = -1;
if (navigator.appName == "Microsoft Internet Explorer"){
var regex = new RegExp("MSIE ([0-9]{1,}[\.0-9]{0,})");
if (regex.exec(navigator.userAgent))
ver = parseFloat(RegExp.$1);
}
return ver;
}
function setText(element, text, succ){
element.className = (succ)?"TestSucc":"TestFail";
element.innerHTML = text;
}
function getByteAt(str, offset){
return str.charCodeAt(offset) & 0xff;
}
function getIntAt(binStr, offset){
return (getByteAt(binStr, offset) << 24)+
(getByteAt(binStr, offset+1) << 16)+
(getByteAt(binStr, offset+2) << 8)+
(getByteAt(binStr, offset+3) >>> 0);
}
function getBlockStr(binStr, offset){
if (getByteAt(binStr, offset) < 254)
return binStr.substring(offset+1, offset+1+binStr.charCodeAt(offset));
else
return binStr.substring(offset+5, offset+5+getIntAt(binStr, offset+1));
}
function doServerTest(){
var version = getInternetExplorerVersion();
if (version==-1 || version>=9.0){
var xmlhttp = (window.XMLHttpRequest)? new XMLHttpRequest() : xmlhttp=new ActiveXObject("Microsoft.XMLHTTP");
xmlhttp.onreadystatechange=function(){
var outputDiv = document.getElementById("ServerTest");
if (xmlhttp.readyState == 4){
if (xmlhttp.status == 200){
var errno = getIntAt(xmlhttp.responseText, 6);
if (errno == 0)
setText(outputDiv, "Connection Success!", true);
else
setText(outputDiv, parseInt(errno)+" - "+getBlockStr(xmlhttp.responseText, 16), false);
}else
setText(outputDiv, "HTTP Error - "+xmlhttp.status, false);
}
}
var params = "";
var form = document.getElementById("TestServerForm");
for (var i=0; i<form.elements.length; i++){
if (i>0) params += "&";
params += form.elements[i].id+"="+form.elements[i].value.replace("&", "%26");
}
document.getElementById("ServerTest").className = "";
document.getElementById("ServerTest").innerHTML = "Connecting...";
xmlhttp.open("POST", "", true);
xmlhttp.setRequestHeader("Content-type", "application/x-www-form-urlencoded");
xmlhttp.setRequestHeader("Content-length", params.length);
xmlhttp.setRequestHeader("Connection", "close");
xmlhttp.send(params);
}else{
document.getElementById("ServerTest").className = "";
document.getElementById("ServerTest").innerHTML = "Internet Explorer "+version+" is not supported, please use Internet explorer 9.0 or above, firefox, chrome or safari";
}
}
</script>
</head>
<body>
<div id="page">
<p>
<font class="Title1">Navicat&trade;</font><br>
<font class="Title2">The gateway to your database!</font>
</p>
<fieldset>
<legend>System Environment Test</legend>
<table>
<tr style="<?php echo "display:none"; ?>"><td width=70%>PHP installed properly</td><td class="TestFail">No</td></tr>
<?php echo doSystemTest();?>
</table>
</fieldset>
<br>
<fieldset>
<legend>Server Test</legend>
<form id="TestServerForm" action="#" onSubmit="return false;">
<input type=hidden id="actn" value="C">
<table>
<tr class="mysql"><td width="35%">Hostname/IP Address:</td><td><input type=text id="host" placeholder="localhost"></td></tr>
<tr class="mysql"><td>Port:</td><td><input type=text id="port" placeholder="3306"></td></tr>
<tr class="pgsql"><td>Initial Database:</td><td><input type=text id="db" placeholder="template1"></td></tr>
<tr class="mysql"><td>Username:</td><td><input type=text id="login" placeholder="root"></td></tr>
<tr class="mysql"><td>Password:</td><td><input type=password id="password" placeholder=""></td></tr>
<tr class="sqlite"><td>Database File:</td><td><input type=text id="dbfile" placeholder="sqlite.db"></td></tr>
<tr><td></td><td><br><input id="TestButton" type="submit" value="Test Connection" onClick="doServerTest()"></td></tr>
</table>
</form>
<div id="ServerTest"><br></div>
</fieldset>
<p id="Copyright">Copyright &copy; PremiumSoft &trade; CyberTech Ltd. All Rights Reserved.</p>
</div>
</body>
</html>

487
Navicat/Navicat Premium 16/resource/httptunnel/ntunnel_pgsql.php Normal file
View File

@@ -0,0 +1,487 @@
<?php
$versionNum = 203; // remark: require update CC_HTTP_TUNNEL_SCRIPT_LATEST_VERSION_PGSQL
//set allowTestMenu to false to disable System/Server test page
$allowTestMenu = true;
header("Content-Type: text/plain; charset=x-user-defined");
error_reporting(0);
set_time_limit(0);
function phpversion_int()
{
list($maVer, $miVer, $edVer) = preg_split("(/|\.|-)", phpversion());
return $maVer*10000 + $miVer*100 + $edVer;
}
if (phpversion_int() < 50300)
{
set_magic_quotes_runtime(0);
}
function GetLongBinary($num)
{
return pack("N",$num);
}
function GetShortBinary($num)
{
return pack("n",$num);
}
function GetDummy($count)
{
$str = "";
for($i=0;$i<$count;$i++)
$str .= "\x00";
return $str;
}
function GetBlock($val)
{
$len = strlen($val);
if( $len < 254 )
return chr($len).$val;
else
return "\xFE".GetLongBinary($len).$val;
}
function EchoHeader($errno)
{
global $versionNum;
$str = GetLongBinary(1111);
$str .= GetShortBinary($versionNum);
$str .= GetLongBinary($errno);
$str .= GetDummy(6);
echo $str;
}
function EchoConnInfo($conn)
{
$str = GetBlock(pg_host($conn));
$protocol = "3";
$version = "";
$is_set = false;
if(function_exists("pg_version")) {
$v = pg_version($conn);
if(array_key_exists('protocol', $v)) {
$protocol = $v['protocol'];
}
if(array_key_exists('server', $v)) {
$version = $v['server'];
$is_set = true;
}
}
if(!$is_set) {
$res = pg_query($conn,"select substring(version(), '[0-9]{1,2}\\.[0-9]{1,2}[\\.|0-9|a-z|A-Z]+')");
if($res) {
$numfields = pg_num_fields($res);
if($numfields == 1) {
$row = pg_fetch_row($res);
if($row) {
$version = $row[0];
}
}
pg_free_result($res);
}
}
$str .= GetBlock($protocol);
$major = 0;
$minor = 0;
$patch_level = 0;
$version_int = 0;
if(sscanf($version, "%d.%d.%d", $major, $minor, $patch_level) >= 3) {
$version_int = $major*10000+$minor*100+$patch_level;
} else if(sscanf($version, "%d.%d%s", $major, $minor, $patch_level) >= 3) {
$version_int = $major*10000+$minor*100;
} else {
$version_int = 0; // returns 0 such that navicat able to handle the server version
}
$str .= GetBlock($version_int);
echo $str;
}
function EchoResultSetHeader($errno, $affectrows, $insertid, $numfields, $numrows)
{
$str = GetLongBinary($errno);
$str .= GetLongBinary($affectrows);
$str .= GetLongBinary($insertid);
$str .= GetLongBinary($numfields);
$str .= GetLongBinary($numrows);
$str .= GetDummy(12);
echo $str;
}
function EchoFieldsHeader($res, $numfields)
{
$str = "";
for( $i = 0; $i < $numfields; $i++ ) {
$str .= GetBlock(pg_field_name($res, $i));
$str .= GetBlock("");
$type = pg_field_type($res, $i);
$length = pg_field_size($res, $i);
switch ($type){
case "boolean": $type=16; break;
case "bytea": $type=17; break;
case "bit": $type=1560; break;
case "varbit": $type=1562; break;
case "char": $type=18; break;
case "name": $type=19; break;
case "int2vector": $type=22; break;
case "oidvector": $type=30; break;
case "int8": $type=20; break;
case "tid": $type=27; break;
case "int2": $type=21; break;
case "int4": $type=23; break;
case "oid": $type=26; break;
case "xid": $type=28; break;
case "cid": $type=29; break;
case "text": $type=25; break;
case "money": $type=790; break;
case "numeric": $type=1700; break;
case "point": $type=600; break;
case "lseg": $type=601; break;
case "path": $type=602; break;
case "box": $type=603; break;
case "polygon": $type=604; break;
case "line": $type=628; break;
case "circle": $type=718; break;
case "float4": $type=700; break;
case "float8": $type=701; break;
case "abstime": $type=702; break;
case "tinterval": $type=704; break;
case "timestamp": $type=1114; break;
case "timestamptz": $type=1184; break;
case "interval": $type=1186; break;
case "timetz": $type=1266; break;
case "unknown": $type=705; break;
case "macaddr": $type=829; break;
case "inet": $type=869; break;
case "cidr": $type=650; break;
case "bpchar": $type=1042; break;
case "varchar": $type=1043; break;
case "date": $type=1082; break;
case "time": $type=1083; break;
case "regproc": $type=24; break;
case "refcursor": $type=1790; break;
case "regprocedure": $type=2202; break;
case "regoper": $type=2203; break;
case "regoperator": $type=2204; break;
case "regclass": $type=2205; break;
case "regtype": $type=2206; break;
default: 0;
}
$str .= GetLongBinary($type);
$str .= GetLongBinary(0);
$str .= GetLongBinary($length);
}
echo $str;
}
function EchoData($res, $numfields, $numrows)
{
for ($i=0; $i < $numrows; $i++ ) {
$str = "";
$row = pg_fetch_row( $res );
for ($j=0; $j < $numfields; $j++ ){
if( is_null($row[$j]) )
$str .= "\xFF";
else
$str .= GetBlock($row[$j]);
}
echo $str;
}
}
if (phpversion_int() < 40005) {
EchoHeader(201);
echo GetBlock("unsupported php version");
exit();
}
if (phpversion_int() < 40010) {
global $HTTP_POST_VARS;
$_POST = &$HTTP_POST_VARS;
}
if (!isset($_POST["actn"]) || !isset($_POST["host"]) || !isset($_POST["port"]) || !isset($_POST["login"])) {
$testMenu = $allowTestMenu;
if (!$testMenu){
EchoHeader(202);
echo GetBlock("invalid parameters");
exit();
}
}
if (!$testMenu){
if ($_POST["encodeBase64"] == '1') {
for($i=0;$i<count($_POST["q"]);$i++)
$_POST["q"][$i] = base64_decode($_POST["q"][$i]);
}
if (!function_exists("pg_connect")) {
EchoHeader(203);
echo GetBlock("PostgresSQL not supported on the server");
exit();
}
$errno_c = 0;
if ($_POST["host"] != "")
$connstr = "host=".$_POST["host"];
$connstr .= " port=".$_POST["port"];
if ($_POST["db"] != "")
$connstr .= " dbname='".$_POST["db"]."'";
else
$connstr .= " dbname='template1'";
$connstr .= " user=".$_POST["login"]." password=".$_POST["password"];
$conn = pg_connect($connstr);
if (!$conn) {
$errno_c = 202;
$error_c = "Could not allocate new connection";
}
EchoHeader($errno_c);
if ($errno_c > 0) {
echo GetBlock($error_c);
} elseif ($_POST["actn"] == "C") {
EchoConnInfo($conn);
} elseif ($_POST["actn"] == "Q") {
for ($i=0; $i < count($_POST["q"]); $i++) {
$query = $_POST["q"][$i];
if ($query == "") continue;
if (phpversion_int() < 50400){
if(get_magic_quotes_gpc())
$query = stripslashes($query);
}
$res = pg_query($conn,$query);
$error = pg_last_error($conn);
if ($error <> "")
$errno = 1;
else
$errno = 0;
$affectedrows = pg_affected_rows($res);
$insertid = 0;
$numfields = pg_num_fields($res);
$numrows = pg_num_rows($res);
EchoResultSetHeader($errno, $affectedrows, $insertid, $numfields, $numrows);
if($errno > 0)
echo GetBlock($error);
else {
if ($numfields > 0) {
EchoFieldsHeader($res, $numfields);
EchoData($res, $numfields, $numrows);
} else
echo GetBlock("");
}
if ($i < (count($_POST["q"])-1))
echo "\x01";
else
echo "\x00";
pg_free_result($res);
}
}
exit();
}
function doSystemTest()
{
global $versionNum;
function output($description, $succ, $resStr) {
echo "<tr><td class=\"TestDesc\">$description</td><td ";
echo ($succ)? "class=\"TestSucc\">$resStr[0]</td></tr>" : "class=\"TestFail\">$resStr[1]</td></tr>";
}
output("PHP version >= 4.0.5", phpversion_int() >= 40005, array("Yes (".phpversion().")", "No (".phpversion().")"));
output("pg_connect() available", function_exists("pg_connect"), array("Yes", "No"));
if (phpversion_int() >= 40302 && substr($_SERVER["SERVER_SOFTWARE"], 0, 6) == "Apache" && function_exists("apache_get_modules")){
if (in_array("mod_security2", apache_get_modules()))
output("Mod Security 2 installed", false, array("No", "Yes"));
}
output("Current tunnel file version", true, array((int)($versionNum / 100) .".". ($versionNum % 100), ""));
}
header("Content-Type: text/html");
?>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<title>Navicat HTTP Tunnel Tester</title>
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<style type="text/css">
body{
margin: 30px;
font-family: Tahoma;
font-weight: normal;
font-size: 14px;
color: #222222;
}
table{
width: 100%;
border: 0px;
}
input{
font-family:Tahoma,sans-serif;
border-style:solid;
border-color:#666666;
border-width:1px;
}
fieldset{
border-style:solid;
border-color:#666666;
border-width:1px;
}
.Title1{
font-size: 30px;
color: #003366;
}
.Title2{
font-size: 10px;
color: #999966;
}
.TestDesc{
width:70%
}
.TestSucc{
color: #00BB00;
}
.TestFail{
color: #DD0000;
}
.mysql{
}
.pgsql{
}
.sqlite{
display:none;
}
#page{
max-width: 42em;
min-width: 36em;
border-width: 0px;
margin: auto auto;
}
#host, #dbfile{
width: 300px;
}
#port{
width: 75px;
}
#login, #password, #db{
width: 150px;
}
#Copyright{
text-align: right;
font-size: 10px;
color: #888888;
}
</style>
<script type="text/javascript">
function getInternetExplorerVersion(){
var ver = -1;
if (navigator.appName == "Microsoft Internet Explorer"){
var regex = new RegExp("MSIE ([0-9]{1,}[\.0-9]{0,})");
if (regex.exec(navigator.userAgent))
ver = parseFloat(RegExp.$1);
}
return ver;
}
function setText(element, text, succ){
element.className = (succ)?"TestSucc":"TestFail";
element.innerHTML = text;
}
function getByteAt(str, offset){
return str.charCodeAt(offset) & 0xff;
}
function getIntAt(binStr, offset){
return (getByteAt(binStr, offset) << 24)+
(getByteAt(binStr, offset+1) << 16)+
(getByteAt(binStr, offset+2) << 8)+
(getByteAt(binStr, offset+3) >>> 0);
}
function getBlockStr(binStr, offset){
if (getByteAt(binStr, offset) < 254)
return binStr.substring(offset+1, offset+1+binStr.charCodeAt(offset));
else
return binStr.substring(offset+5, offset+5+getIntAt(binStr, offset+1));
}
function doServerTest(){
var version = getInternetExplorerVersion();
if (version==-1 || version>=9.0){
var xmlhttp = (window.XMLHttpRequest)? new XMLHttpRequest() : xmlhttp=new ActiveXObject("Microsoft.XMLHTTP");
xmlhttp.onreadystatechange=function(){
var outputDiv = document.getElementById("ServerTest");
if (xmlhttp.readyState == 4){
if (xmlhttp.status == 200){
var errno = getIntAt(xmlhttp.responseText, 6);
if (errno == 0)
setText(outputDiv, "Connection Success!", true);
else
setText(outputDiv, parseInt(errno)+" - "+getBlockStr(xmlhttp.responseText, 16), false);
}else
setText(outputDiv, "HTTP Error - "+xmlhttp.status, false);
}
}
var params = "";
var form = document.getElementById("TestServerForm");
for (var i=0; i<form.elements.length; i++){
if (i>0) params += "&";
params += form.elements[i].id+"="+form.elements[i].value.replace("&", "%26");
}
document.getElementById("ServerTest").className = "";
document.getElementById("ServerTest").innerHTML = "Connecting...";
xmlhttp.open("POST", "", true);
xmlhttp.setRequestHeader("Content-type", "application/x-www-form-urlencoded");
xmlhttp.setRequestHeader("Content-length", params.length);
xmlhttp.setRequestHeader("Connection", "close");
xmlhttp.send(params);
}else{
document.getElementById("ServerTest").className = "";
document.getElementById("ServerTest").innerHTML = "Internet Explorer "+version+" is not supported, please use Internet explorer 9.0 or above, firefox, chrome or safari";
}
}
</script>
</head>
<body>
<div id="page">
<p>
<font class="Title1">Navicat&trade;</font><br>
<font class="Title2">The gateway to your database!</font>
</p>
<fieldset>
<legend>System Environment Test</legend>
<table>
<tr style="<?php echo "display:none"; ?>"><td width=70%>PHP installed properly</td><td class="TestFail">No</td></tr>
<?php echo doSystemTest();?>
</table>
</fieldset>
<br>
<fieldset>
<legend>Server Test</legend>
<form id="TestServerForm" action="#" onSubmit="return false;">
<input type=hidden id="actn" value="C">
<table>
<tr class="mysql"><td width="35%">Hostname/IP Address:</td><td><input type=text id="host" placeholder="localhost"></td></tr>
<tr class="mysql"><td>Port:</td><td><input type=text id="port" placeholder="5432"></td></tr>
<tr class="pgsql"><td>Initial Database:</td><td><input type=text id="db" placeholder="template1"></td></tr>
<tr class="mysql"><td>Username:</td><td><input type=text id="login" placeholder="postgres"></td></tr>
<tr class="mysql"><td>Password:</td><td><input type=password id="password" placeholder=""></td></tr>
<tr class="sqlite"><td>Database File:</td><td><input type=text id="dbfile" placeholder="sqlite.db"></td></tr>
<tr><td></td><td><br><input id="TestButton" type="submit" value="Test Connection" onClick="doServerTest()"></td></tr>
</table>
</form>
<div id="ServerTest"><br></div>
</fieldset>
<p id="Copyright">Copyright &copy; PremiumSoft &trade; CyberTech Ltd. All Rights Reserved.</p>
</div>
</body>
</html>

577
Navicat/Navicat Premium 16/resource/httptunnel/ntunnel_sqlite.php Normal file
View File

@@ -0,0 +1,577 @@
<?php
$versionNum = 203; // remark: require update CC_HTTP_TUNNEL_SCRIPT_LATEST_VERSION_SQLITE
//set allowTestMenu to false to disable System/Server test page
$allowTestMenu = true;
header("Content-Type: text/plain; charset=x-user-defined");
error_reporting(0);
set_time_limit(0);
define('FileDoesNotExist', 0);
define('FileCannotBeOpened', 1);
define('FileIsSQLite2', 2);
define('FileIsSQLite3', 3);
define('FileIsInvalid', 4);
function phpversion_int()
{
list($maVer, $miVer, $edVer) = preg_split("(/|\.|-)", phpversion());
return $maVer*10000 + $miVer*100 + $edVer;
}
if (phpversion_int() < 50300)
{
set_magic_quotes_runtime(0);
}
function GetLongBinary($num)
{
return pack("N",$num);
}
function GetShortBinary($num)
{
return pack("n",$num);
}
function GetDummy($count)
{
$str = "";
for($i=0;$i<$count;$i++)
$str .= "\x00";
return $str;
}
function GetBlock($val)
{
$len = strlen($val);
if( $len < 254 )
return chr($len).$val;
else
return "\xFE".GetLongBinary($len).$val;
}
function EchoHeader($errno)
{
global $versionNum;
$str = GetLongBinary(1111);
$str .= GetShortBinary($versionNum);
$str .= GetLongBinary($errno);
$str .= GetDummy(6);
echo $str;
}
function EchoConnInfo()
{
$version = sqlite_libversion();
$str = GetBlock($version);
$str .= GetBlock($version);
$str .= GetBlock($version);
echo $str;
}
function EchoConnInfo3()
{
$version = SQLite3::version();
$str = GetBlock($version["versionString"]);
$str .= GetBlock($version["versionString"]);
$str .= GetBlock($version["versionString"]);
echo $str;
}
function EchoResultSetHeader($errno, $affectrows, $insertid, $numfields, $numrows)
{
$str = GetLongBinary($errno);
$str .= GetLongBinary($affectrows);
$str .= GetLongBinary($insertid);
$str .= GetLongBinary($numfields);
$str .= GetLongBinary($numrows);
$str .= GetDummy(12);
echo $str;
}
function EchoFieldsHeader($res, $numfields)
{
$str = "";
for ( $i = 0; $i < $numfields; $i++ ) {
$str .= GetBlock(sqlite_field_name($res, $i));
$str .= GetBlock("");
$type = -2; // SQLITE_TEXT
$length = 0;
$flag = 0;
$str .= GetLongBinary($type);
$str .= GetLongBinary($flag);
$str .= GetLongBinary($length);
}
echo $str;
}
function EchoFieldsHeader3($res, $numfields)
{
$str = "";
for ( $i = 0; $i < $numfields; $i++ ) {
$str .= GetBlock($res->columnName($i));
$str .= GetBlock("");
$type = SQLITE3_NULL;
$length = 0;
$flag = 0;
$str .= GetLongBinary($type);
$str .= GetLongBinary($flag);
$str .= GetLongBinary($length);
}
echo $str;
}
function EchoData($res, $numfields, $numrows)
{
for ( $i = 0; $i < $numrows; $i++ ) {
$str = "";
$row = sqlite_fetch_array( $res, SQLITE_NUM );
for( $j = 0; $j < $numfields; $j++ ) {
if( is_null($row[$j]) )
$str .= "\xFF";
else
$str .= GetBlock($row[$j]);
$str .= GetLongBinary(-2);
}
echo $str;
}
}
function EchoData3($res, $numfields, $numrows)
{
while ($row = $res->fetchArray(SQLITE3_NUM)) {
$str = "";
for ( $j = 0; $j < $numfields; $j++ ) {
if ( is_null($row[$j]) )
$str .= "\xFF";
else
$str .= GetBlock($row[$j]);
$str .= GetLongBinary($res->columnType($j));
}
echo $str;
}
}
function SQLite2($action, $path, $queries)
{
if (!function_exists("sqlite_open")) {
EchoHeader(203);
echo GetBlock("SQLite2 is not supported on the server");
exit();
}
$errno_c = 0;
$conn = sqlite_open($path, 0666, $error_c);
if ($conn == FALSE) {
$errno_c = 202;
}
EchoHeader($errno_c);
if ($errno_c > 0) {
echo GetBlock(sqlite_error_string($error_c));
} elseif($action == "C") {
EchoConnInfo();
} elseif($action == "2") {
sqlite_query($conn, "VACUUM");
EchoConnInfo();
} elseif($action == "Q") {
for($i=0;$i<count($queries);$i++) {
$query = $queries[$i];
if ($query == "") continue;
if (phpversion_int() < 50400){
if(get_magic_quotes_gpc())
$query = stripslashes($query);
}
$res = sqlite_query($conn, $query);
$errno = sqlite_last_error($conn);
$affectedrows = sqlite_changes($conn);
$insertid = sqlite_last_insert_rowid($conn);
$numfields = sqlite_num_fields($res);
$numrows = sqlite_num_rows($res);
EchoResultSetHeader($errno, $affectedrows, $insertid, $numfields, $numrows);
if ($errno != 0)
echo GetBlock(sqlite_error_string($errno));
else {
if ($numfields > 0) {
EchoFieldsHeader($res, $numfields);
EchoData($res, $numfields, $numrows);
} else {
echo GetBlock("");
}
}
if ($i<(count($queries)-1))
echo "\x01";
else
echo "\x00";
}
}
sqlite_close($conn);
}
function SQLite3($action, $path, $queries)
{
if (!class_exists("Sqlite3")) {
EchoHeader(203);
echo GetBlock("SQLite3 is not supported on the server");
exit();
}
$flag = SQLITE3_OPEN_READWRITE;
if ($action == "3")
$flag = SQLITE3_OPEN_READWRITE | SQLITE3_OPEN_CREATE;
$errno_c = 0;
$conn = new SQLite3($path, $flag);
if ($conn == nil) {
$errno_c = 202;
}
EchoHeader($errno_c);
if ($errno_c > 0) {
echo GetBlock(SQLite3::lastErrorMsg());
} else if($action == "C") {
EchoConnInfo3();
} else if($action == "3") {
$conn->query("VACUUM");
EchoConnInfo3();
} else if($action == "Q") {
for($i=0;$i<count($queries);$i++) {
$query = $queries[$i];
if ($query == "") continue;
if (phpversion_int() < 50400){
if(get_magic_quotes_gpc())
$query = stripslashes($query);
}
$res = $conn->query($query);
$errno = $conn->lastErrorCode();
$affectedrows = $conn->changes();
$insertid = $conn->lastInsertRowID();
$numfields = 0;
$numrows = 0;
if (is_a($res, "SQLite3Result")) {
$numfields = $res->numColumns();
if ($numfields > 0) {
while ($row = $res->fetchArray(SQLITE3_NUM)) {
$numrows++;
}
$res->reset();
}
}
EchoResultSetHeader($errno, $affectedrows, $insertid, $numfields, $numrows);
if ($errno != 0)
echo GetBlock($conn->lastErrorMsg());
else {
if ($numfields > 0) {
EchoFieldsHeader3($res, $numfields);
EchoData3($res, $numfields, $numrows);
$res->finalize();
} else {
echo GetBlock("");
}
}
if ($i<(count($queries)-1))
echo "\x01";
else
echo "\x00";
}
}
$conn->close();
}
if (phpversion_int() < 50000) {
EchoHeader(201);
echo GetBlock("unsupported php version");
exit();
}
if (!isset($_POST["actn"]) || !isset($_POST["dbfile"])) {
$testMenu = $allowTestMenu;
if (!$testMenu){
EchoHeader(202);
echo GetBlock("invalid parameters");
exit();
}
}
if (!$testMenu){
if ($action == "2" || $action == "3") {
if (!isset($_POST["version"])) {
EchoHeader(202);
echo GetBlock("invalid parameters");
exit();
}
}
if ($_POST["encodeBase64"] == '1') {
for($i=0;$i<count($_POST["q"]);$i++)
$_POST["q"][$i] = base64_decode($_POST["q"][$i]);
}
$action = $_POST["actn"];
$file = $_POST["dbfile"];
$queries = $_POST["q"];
$status = FileDoesNotExist;
if (is_file($file)) {
$fhandle = fopen($file, "r");
if ($fhandle) {
$sqlite2header = "** This file contains an SQLite 2.1 database **";
$sqlite3header = "SQLite format 3";
$string = fread($fhandle, strlen($sqlite2header));
if (strncmp($string, $sqlite2header, strlen($sqlite2header)) == 0)
$status = FileIsSQLite2;
else if ($string == "" || strncmp(substr($string, 0, strlen($sqlite3header)), $sqlite3header, strlen($sqlite3header)) == 0)
$status = FileIsSQLite3;
else
$status = FileIsInvalid;
fclose($fhandle);
} else {
$status = FileCannotBeOpened;
}
}
if ($action == "2" || $action == "3") {
if ($status == FileDoesNotExist) {
if ($action == "2")
SQLite2($action, $file, $queries);
else
SQLite3($action, $file, $queries);
} else {
EchoHeader(202);
echo GetBlock("Datbase file exists already");
}
} else {
switch ($status) {
case FileDoesNotExist:
EchoHeader(202);
echo GetBlock("Database file does not exist");
break;
case FileCannotBeOpened:
EchoHeader(202);
echo GetBlock("Database file cannot be opened");
break;
case FileIsSQLite2:
SQLite2($action, $file, $queries);
break;
case FileIsSQLite3:
SQLite3($action, $file, $queries);
break;
case FileIsInvalid:
EchoHeader(202);
echo GetBlock("Database file is encrypted or invalid");
break;
}
}
exit();
}
function doSystemTest()
{
global $versionNum;
function output($description, $succ, $resStr) {
echo "<tr><td class=\"TestDesc\">$description</td><td ";
echo ($succ)? "class=\"TestSucc\">$resStr[0]</td></tr>" : "class=\"TestFail\">$resStr[1]</td></tr>";
}
output("[SQLite2] PHP version >= 5.0.0", phpversion_int() >= 50000, array("Yes (".phpversion().")", "No (".phpversion().")"));
output("[SQLite2] sqlite_open() available", function_exists("sqlite_open"), array("Yes", "No"));
output("[SQLite3] PHP version >= 5.3.0", phpversion_int() >= 50300, array("Yes (".phpversion().")", "No (".phpversion().")"));
output("[SQLite3] SQLite3 class available", class_exists("SQLite3"), array("Yes", "No"));
if (phpversion_int() >= 40302 && substr($_SERVER["SERVER_SOFTWARE"], 0, 6) == "Apache" && function_exists("apache_get_modules")){
if (in_array("mod_security2", apache_get_modules()))
output("Mod Security 2 installed", false, array("No", "Yes"));
}
output("Current tunnel file version", true, array((int)($versionNum / 100) .".". ($versionNum % 100), ""));
}
header("Content-Type: text/html");
?>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<title>Navicat HTTP Tunnel Tester</title>
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<style type="text/css">
body{
margin: 30px;
font-family: Tahoma;
font-weight: normal;
font-size: 14px;
color: #222222;
}
table{
width: 100%;
border: 0px;
}
input{
font-family:Tahoma,sans-serif;
border-style:solid;
border-color:#666666;
border-width:1px;
}
fieldset{
border-style:solid;
border-color:#666666;
border-width:1px;
}
.Title1{
font-size: 30px;
color: #003366;
}
.Title2{
font-size: 10px;
color: #999966;
}
.TestDesc{
width:70%
}
.TestSucc{
color: #00BB00;
}
.TestFail{
color: #DD0000;
}
.mysql{
display:none;
}
.pgsql{
display:none;
}
.sqlite{
}
#page{
max-width: 42em;
min-width: 36em;
border-width: 0px;
margin: auto auto;
}
#host, #dbfile{
width: 300px;
}
#port{
width: 75px;
}
#login, #password, #db{
width: 150px;
}
#Copyright{
text-align: right;
font-size: 10px;
color: #888888;
}
</style>
<script type="text/javascript">
function getInternetExplorerVersion(){
var ver = -1;
if (navigator.appName == "Microsoft Internet Explorer"){
var regex = new RegExp("MSIE ([0-9]{1,}[\.0-9]{0,})");
if (regex.exec(navigator.userAgent))
ver = parseFloat(RegExp.$1);
}
return ver;
}
function setText(element, text, succ){
element.className = (succ)?"TestSucc":"TestFail";
element.innerHTML = text;
}
function getByteAt(str, offset){
return str.charCodeAt(offset) & 0xff;
}
function getIntAt(binStr, offset){
return (getByteAt(binStr, offset) << 24)+
(getByteAt(binStr, offset+1) << 16)+
(getByteAt(binStr, offset+2) << 8)+
(getByteAt(binStr, offset+3) >>> 0);
}
function getBlockStr(binStr, offset){
if (getByteAt(binStr, offset) < 254)
return binStr.substring(offset+1, offset+1+binStr.charCodeAt(offset));
else
return binStr.substring(offset+5, offset+5+getIntAt(binStr, offset+1));
}
function doServerTest(){
var version = getInternetExplorerVersion();
if (version==-1 || version>=9.0){
var xmlhttp = (window.XMLHttpRequest)? new XMLHttpRequest() : xmlhttp=new ActiveXObject("Microsoft.XMLHTTP");
xmlhttp.onreadystatechange=function(){
var outputDiv = document.getElementById("ServerTest");
if (xmlhttp.readyState == 4){
if (xmlhttp.status == 200){
var errno = getIntAt(xmlhttp.responseText, 6);
if (errno == 0)
setText(outputDiv, "Connection Success!", true);
else
setText(outputDiv, parseInt(errno)+" - "+getBlockStr(xmlhttp.responseText, 16), false);
}else
setText(outputDiv, "HTTP Error - "+xmlhttp.status, false);
}
}
var params = "";
var form = document.getElementById("TestServerForm");
for (var i=0; i<form.elements.length; i++){
if (i>0) params += "&";
params += form.elements[i].id+"="+form.elements[i].value.replace("&", "%26");
}
document.getElementById("ServerTest").className = "";
document.getElementById("ServerTest").innerHTML = "Connecting...";
xmlhttp.open("POST", "", true);
xmlhttp.setRequestHeader("Content-type", "application/x-www-form-urlencoded");
xmlhttp.setRequestHeader("Content-length", params.length);
xmlhttp.setRequestHeader("Connection", "close");
xmlhttp.send(params);
}else{
document.getElementById("ServerTest").className = "";
document.getElementById("ServerTest").innerHTML = "Internet Explorer "+version+" is not supported, please use Internet explorer 9.0 or above, firefox, chrome or safari";
}
}
</script>
</head>
<body>
<div id="page">
<p>
<font class="Title1">Navicat&trade;</font><br>
<font class="Title2">The gateway to your database!</font>
</p>
<fieldset>
<legend>System Environment Test</legend>
<table>
<tr style="<?php echo "display:none"; ?>"><td width=70%>PHP installed properly</td><td class="TestFail">No</td></tr>
<?php echo doSystemTest();?>
</table>
</fieldset>
<br>
<fieldset>
<legend>Server Test</legend>
<form id="TestServerForm" action="#" onSubmit="return false;">
<input type=hidden id="actn" value="C">
<table>
<tr class="mysql"><td width="35%">Hostname/IP Address:</td><td><input type=text id="host" placeholder="localhost"></td></tr>
<tr class="mysql"><td>Port:</td><td><input type=text id="port" placeholder=""></td></tr>
<tr class="pgsql"><td>Initial Database:</td><td><input type=text id="db" placeholder="template1"></td></tr>
<tr class="mysql"><td>Username:</td><td><input type=text id="login" placeholder=""></td></tr>
<tr class="mysql"><td>Password:</td><td><input type=password id="password" placeholder=""></td></tr>
<tr class="sqlite"><td>Database File:</td><td><input type=text id="dbfile" placeholder="sqlite.db"></td></tr>
<tr><td></td><td><br><input id="TestButton" type="submit" value="Test Connection" onClick="doServerTest()"></td></tr>
</table>
</form>
<div id="ServerTest"><br></div>
</fieldset>
<p id="Copyright">Copyright &copy; PremiumSoft &trade; CyberTech Ltd. All Rights Reserved.</p>
</div>
</body>
</html>