574 lines
20 KiB
PHP
574 lines
20 KiB
PHP
<?php
|
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
|
class Net
|
|
{
|
|
public $hostname;
|
|
public $ip;
|
|
|
|
private $db_user;
|
|
private $db_passwd;
|
|
private $db_sourcename;
|
|
private $db_port;
|
|
private $db_instance;
|
|
|
|
/*errors handle*/
|
|
public $error;
|
|
public $errno;
|
|
public $errstr;
|
|
|
|
public function __construct()
|
|
{
|
|
$a = func_get_args();
|
|
$f = "init" . func_num_args();
|
|
|
|
if (method_exists($this, $f)) {
|
|
call_user_func_array(array($this, $f), $a);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* This function is the constructor of the class net
|
|
*
|
|
* return void
|
|
*/
|
|
protected function init0()
|
|
{
|
|
$this->errno = 0;
|
|
$this->error = "";
|
|
}
|
|
|
|
/**
|
|
* This function is the constructor of the class net
|
|
*
|
|
* @param string $pHost
|
|
* @return void
|
|
*/
|
|
protected function init1($pHost)
|
|
{
|
|
$this->errno = 0;
|
|
$this->errstr = "";
|
|
$this->db_instance = "";
|
|
|
|
unset($this->db_user);
|
|
unset($this->db_passwd);
|
|
unset($this->db_sourcename);
|
|
|
|
#verifing valid param
|
|
if ($pHost == "") {
|
|
$this->errno = 1000;
|
|
$this->errstr = "NET::You must specify a host";
|
|
//$this->showMsg();
|
|
}
|
|
$this->resolv($pHost);
|
|
}
|
|
|
|
/**
|
|
* This function puts a host
|
|
*
|
|
* @param string $pHost
|
|
* @return void
|
|
*/
|
|
public function resolv($pHost)
|
|
{
|
|
$aHost = explode("\\", $pHost);
|
|
if (count($aHost) > 1) {
|
|
$ipHost = $aHost[0];
|
|
$this->db_instance = $aHost[1];
|
|
} else {
|
|
$ipHost = $pHost;
|
|
}
|
|
if ($this->is_ipaddress($ipHost)) {
|
|
$this->ip = $ipHost;
|
|
if (!$this->hostname = @gethostbyaddr($ipHost)) {
|
|
$this->errno = 2000;
|
|
$this->errstr = "NET::Host down";
|
|
$this->error = G::loadTranslation('ID_HOST_UNREACHABLE');
|
|
}
|
|
} else {
|
|
$ip = @gethostbyname($ipHost);
|
|
$long = ip2long($ip);
|
|
if ($long == -1 || $long === false) {
|
|
$this->errno = 2000;
|
|
$this->errstr = "NET::Host down";
|
|
$this->error = G::loadTranslation('ID_HOST_UNREACHABLE');
|
|
} else {
|
|
$this->ip = @gethostbyname($ipHost);
|
|
$this->hostname = $pHost;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* This function resolves IP from Hostname returns hostname on failure
|
|
*
|
|
* @param string $pPort
|
|
* @return true
|
|
*/
|
|
public function scannPort($pPort)
|
|
{
|
|
define('TIMEOUT', 5);
|
|
$hostip = @gethostbyname($host); // resloves IP from Hostname returns hostname on failure
|
|
// attempt to connect
|
|
if (@fsockopen($this->ip, $pPort, $this->errno, $this->errstr, TIMEOUT)) {
|
|
return true;
|
|
@fclose($x); //close connection (i dont know if this is needed or not).
|
|
} else {
|
|
$this->errno = 9999;
|
|
$this->errstr = "NET::Port Host Unreachable";
|
|
$this->error = G::loadTranslation('ID_PORT_UNREACHABLE');
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* This function checks if it is a ip address
|
|
*
|
|
* @param string $pHost
|
|
* @return true
|
|
*/
|
|
public function is_ipaddress($pHost)
|
|
{
|
|
$key = true;
|
|
#verifing if is a ip address
|
|
$tmp = explode(".", $pHost);
|
|
#if have a ip address format
|
|
if (count($tmp) == 4) {
|
|
#if a correct ip address
|
|
for ($i = 0; $i < count($tmp); $i++) {
|
|
if (!is_int($tmp[$i])) {
|
|
$key = false;
|
|
break;
|
|
}
|
|
}
|
|
} else {
|
|
$key = false;
|
|
}
|
|
return $key;
|
|
}
|
|
|
|
/**
|
|
* This function executes pin -w time IP
|
|
*
|
|
* @param string $pHost
|
|
* @return true
|
|
*/
|
|
public function ping($pTTL = 3000)
|
|
{
|
|
$cmd = "ping -w $pTTL $this->ip";
|
|
$output = exec($cmd, $a, $a1);
|
|
$this->errstr = "";
|
|
for ($i = 0; $i < count($a); $i++) {
|
|
$this->errstr += $a[$i];
|
|
}
|
|
$this->errno = $a1;
|
|
}
|
|
|
|
/**
|
|
* This function logins in db
|
|
*
|
|
* @param string $pUser
|
|
* @param string $pPasswd
|
|
* @return void
|
|
*/
|
|
public function loginDbServer($pUser, $pPasswd)
|
|
{
|
|
$this->db_user = $pUser;
|
|
$this->db_passwd = $pPasswd;
|
|
}
|
|
|
|
/**
|
|
* This function sets db
|
|
*
|
|
* @param string $pDb
|
|
* @param string $pPort
|
|
* @return void
|
|
*/
|
|
public function setDataBase($pDb, $pPort = '')
|
|
{
|
|
$this->db_sourcename = $pDb;
|
|
$this->db_port = $pPort;
|
|
}
|
|
|
|
/**
|
|
* This function tries to connect to server
|
|
*
|
|
* @param string $pDbDriver
|
|
* @param array $arrayServerData
|
|
*
|
|
* @return void
|
|
*/
|
|
public function tryConnectServer($pDbDriver, array $arrayServerData = array(), $dbsEncode = "")
|
|
{
|
|
$filter = new InputFilter();
|
|
$this->ip = $filter->validateInput($this->ip);
|
|
$this->db_port = $filter->validateInput($this->db_port, 'int');
|
|
$this->db_user = $filter->validateInput($this->db_user);
|
|
$this->db_passwd = $filter->validateInput($this->db_passwd);
|
|
$this->db_sourcename = $filter->validateInput($this->db_sourcename);
|
|
if ($this->errno != 0) {
|
|
return 0;
|
|
}
|
|
$stat = new Stat();
|
|
|
|
if (array_key_exists("connectionType", $arrayServerData) || array_key_exists("DBS_TYPEORACLE", $arrayServerData)) {
|
|
if ($arrayServerData["connectionType"] == "TNS" || $arrayServerData["DBS_TYPEORACLE"] == "TNS") {
|
|
$flagTns = 1;
|
|
} else {
|
|
$flagTns = 0;
|
|
}
|
|
} else {
|
|
$flagTns = 0;
|
|
}
|
|
|
|
if (isset($this->db_user) && (isset($this->db_passwd) || $this->db_passwd == "") && (isset($this->db_sourcename) || $flagTns == 1)) {
|
|
switch ($pDbDriver) {
|
|
case 'mysql':
|
|
|
|
try {
|
|
InstallerModule::setNewConnection('NET', $this->ip, $this->db_user, $this->db_passwd, $this->db_sourcename, $this->db_port);
|
|
$stat->status = 'SUCCESS';
|
|
$this->errstr = '';
|
|
$this->errno = 0;
|
|
} catch (Exception $exception) {
|
|
$this->error = 'MySql connection refused!';
|
|
$this->errstr = 'NET::MYSQL->The connection was refused';
|
|
$this->errno = 10001;
|
|
}
|
|
break;
|
|
case 'pgsql':
|
|
//todo
|
|
$this->db_port = ($this->db_port == "") ? "5432" : $this->db_port;
|
|
$link = @pg_connect("host='$this->ip' port='$this->db_port' user='$this->db_user' password='$this->db_passwd' dbname='$this->db_sourcename'");
|
|
if ($link) {
|
|
$stat->status = 'SUCCESS';
|
|
$this->errstr = "";
|
|
$this->errno = 0;
|
|
} else {
|
|
$this->error = "PostgreSql connection refused!";
|
|
$this->errstr = "NET::POSTGRES->The connection was refused";
|
|
$this->errno = 20001;
|
|
}
|
|
break;
|
|
case 'mssql':
|
|
case 'sqlsrv':
|
|
if ($this->db_instance != "") {
|
|
$server = $this->ip . "\\" . $this->db_instance;
|
|
} else {
|
|
$server = $this->ip;
|
|
}
|
|
$port = (($this->db_port == "") || ($this->db_port == 0) || ($this->db_port == 1433)) ? "" : ", " . $this->db_port;
|
|
$server .= $port;
|
|
$opt = [
|
|
'UID' => $this->db_user,
|
|
'PWD' => $this->db_passwd,
|
|
'Database' => $this->db_sourcename,
|
|
'CharacterSet' => 'UTF-8',
|
|
'Encrypt' => true,
|
|
'TrustServerCertificate' => true
|
|
];
|
|
$link = @sqlsrv_connect($server, $opt);
|
|
|
|
if ($link) {
|
|
$stat->status = 'SUCCESS';
|
|
$this->errstr = "";
|
|
$this->errno = 0;
|
|
} else {
|
|
$this->error = "MS-SQL Server connection refused";
|
|
$this->errstr = "NET::MSSQL->The connection was refused";
|
|
$this->errno = 30001;
|
|
}
|
|
break;
|
|
case 'oracle':
|
|
//todo
|
|
try {
|
|
if ($flagTns == 0) {
|
|
$this->db_port = ($this->db_port == "" || $this->db_port == 0) ? "1521" : $this->db_port;
|
|
|
|
$cnn = @oci_connect($this->db_user, $this->db_passwd, "(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP) (HOST=$this->ip) (PORT=$this->db_port) )) (CONNECT_DATA=(SERVICE_NAME=$this->db_sourcename)))", $dbsEncode);
|
|
} else {
|
|
$cnn = @oci_connect($this->db_user, $this->db_passwd, $arrayServerData["tns"], $dbsEncode);
|
|
}
|
|
|
|
if ($cnn) {
|
|
$stat->status = "SUCCESS";
|
|
$this->errstr = "";
|
|
$this->errno = 0;
|
|
} else {
|
|
$this->error = "Oracle connection refused";
|
|
$this->errstr = "NET::ORACLE->The connection was refused";
|
|
$this->errno = 30001;
|
|
}
|
|
} catch (Exception $e) {
|
|
throw new Exception("[erik] Couldn't connect to Oracle Server! - " . $e->getMessage());
|
|
}
|
|
break;
|
|
case 'informix':
|
|
break;
|
|
case 'sqlite':
|
|
break;
|
|
}
|
|
} else {
|
|
throw new Exception("CLASS::NET::ERROR: No connections param.");
|
|
}
|
|
|
|
return $stat;
|
|
}
|
|
|
|
/**
|
|
* This function tries to open to the DB
|
|
*
|
|
* @param string $pDbDriver
|
|
* @param array $arrayServerData
|
|
*
|
|
* @return void
|
|
*/
|
|
public function tryOpenDataBase($pDbDriver, array $arrayServerData = array(), $dbsEncode = "")
|
|
{
|
|
$filter = new InputFilter();
|
|
$this->ip = $filter->validateInput($this->ip);
|
|
$this->db_port = $filter->validateInput($this->db_port, 'int');
|
|
$this->db_user = $filter->validateInput($this->db_user);
|
|
$this->db_passwd = $filter->validateInput($this->db_passwd);
|
|
$this->db_sourcename = $filter->validateInput($this->db_sourcename);
|
|
if ($this->errno != 0) {
|
|
return 0;
|
|
}
|
|
|
|
set_time_limit(0);
|
|
$stat = new Stat();
|
|
|
|
if (array_key_exists("connectionType", $arrayServerData) || array_key_exists("DBS_TYPEORACLE", $arrayServerData)) {
|
|
if ($arrayServerData["connectionType"] == "TNS" || $arrayServerData["DBS_TYPEORACLE"] == "TNS") {
|
|
$flagTns = 1;
|
|
} else {
|
|
$flagTns = 0;
|
|
}
|
|
} else {
|
|
$flagTns = 0;
|
|
}
|
|
|
|
if (isset($this->db_user) && (isset($this->db_passwd) || $this->db_passwd == "") && (isset($this->db_sourcename) || $flagTns == 1)) {
|
|
switch ($pDbDriver) {
|
|
case 'mysql':
|
|
try {
|
|
$this->errstr = 'NET::MYSQL->The connection was refused';
|
|
$this->errno = 10001;
|
|
$connection = 'NET_' . $this->db_sourcename;
|
|
InstallerModule::setNewConnection($connection, $this->ip, $this->db_user, $this->db_passwd, $this->db_sourcename, $this->db_port);
|
|
|
|
$this->errstr = 'NET::MYSQL->Test query failed';
|
|
$this->errno = 10100;
|
|
|
|
$result = DB::connection($connection)->statement('show tables');
|
|
if ($result) {
|
|
$stat->status = 'SUCCESS';
|
|
$this->errstr = '';
|
|
$this->errno = 0;
|
|
}
|
|
} catch (Exception $exception) {
|
|
$this->error = $exception->getMessage();
|
|
}
|
|
break;
|
|
case 'pgsql':
|
|
$this->db_port = (($this->db_port == "") || ($this->db_port == 0)) ? "5432" : $this->db_port;
|
|
$link = @pg_connect("host='$this->ip' port='$this->db_port' user='$this->db_user' password='$this->db_passwd' dbname='$this->db_sourcename'");
|
|
if ($link) {
|
|
if (@pg_ping($link)) {
|
|
$stat->status = 'SUCCESS';
|
|
$this->errstr = "";
|
|
$this->errno = 0;
|
|
} else {
|
|
$this->error = "PostgreSql Connection to $this->ip is unreachable!";
|
|
$this->errstr = "NET::POSTGRES->Lost Connection";
|
|
$this->errno = 20010;
|
|
}
|
|
} else {
|
|
$this->error = "PostgrSql connection refused";
|
|
$this->errstr = "NET::POSTGRES->The connection was refused";
|
|
$this->errno = 20001;
|
|
}
|
|
break;
|
|
case 'mssql':
|
|
case 'sqlsrv':
|
|
if ($this->db_instance != "") {
|
|
$server = $this->ip . "\\" . $this->db_instance;
|
|
} else {
|
|
$server = $this->ip;
|
|
}
|
|
$port = (($this->db_port == "") || ($this->db_port == 0) || ($this->db_port == 1433)) ? "" : ", " . $this->db_port;
|
|
$server .= $port;
|
|
$opt = [
|
|
'UID' => $this->db_user,
|
|
'PWD' => $this->db_passwd,
|
|
'Database' => $this->db_sourcename,
|
|
'CharacterSet' => 'UTF-8',
|
|
'Encrypt' => true,
|
|
'TrustServerCertificate' => true
|
|
];
|
|
$link = $db = @sqlsrv_connect($server, $opt);
|
|
if ($link) {
|
|
if ($db) {
|
|
$stat->status = 'SUCCESS';
|
|
$this->errstr = "";
|
|
$this->errno = 0;
|
|
} else {
|
|
$this->error = "The $this->db_sourcename data base does'n exist!";
|
|
$this->errstr = "NET::MSSQL->Select data base failed";
|
|
$this->errno = 30010;
|
|
}
|
|
} else {
|
|
$this->error = "MS-SQL Server connection refused!";
|
|
$this->errstr = "NET::MSSQL->The connection was refused";
|
|
$this->errno = 30001;
|
|
}
|
|
break;
|
|
case 'oracle':
|
|
if ($flagTns == 0) {
|
|
$this->db_port = ($this->db_port == "" || $this->db_port == 0) ? "1521" : $this->db_port;
|
|
|
|
$cnn = @oci_connect($this->db_user, $this->db_passwd, "(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP) (HOST=$this->ip) (PORT=$this->db_port) )) (CONNECT_DATA=(SERVICE_NAME=$this->db_sourcename)))", $dbsEncode);
|
|
} else {
|
|
$cnn = @oci_connect($this->db_user, $this->db_passwd, $arrayServerData["tns"], $dbsEncode);
|
|
}
|
|
|
|
if ($cnn) {
|
|
$stid = @oci_parse($cnn, 'select AUTHENTICATION_TYPE from v$session_connect_info');
|
|
$result = @oci_execute($stid, OCI_DEFAULT);
|
|
if ($result) {
|
|
$stat->status = 'SUCCESS';
|
|
$this->errstr = "";
|
|
$this->errno = 0;
|
|
@oci_close($cnn);
|
|
} else {
|
|
$this->error = "the user $this->db_user doesn't have privileges to run queries!";
|
|
$this->errstr = "NET::ORACLE->Couldn't execute any query on this server!";
|
|
$this->errno = 40010;
|
|
}
|
|
} else {
|
|
$this->error = "Oracle connection refused!";
|
|
$this->errstr = "NET::ORACLE->The connection was refused";
|
|
$this->errno = 40001;
|
|
}
|
|
break;
|
|
case 'informix':
|
|
break;
|
|
case 'sqlite':
|
|
break;
|
|
}
|
|
} else {
|
|
throw new Exception("CLASS::NET::ERROR: No connections param.");
|
|
}
|
|
return $stat;
|
|
}
|
|
|
|
/**
|
|
* This function gets DB-s version
|
|
*
|
|
* @param string $driver
|
|
* @return void
|
|
*/
|
|
public function getDbServerVersion($driver)
|
|
{
|
|
if (!isset($this->ip)) {
|
|
$this->ip = getenv('HTTP_CLIENT_IP');
|
|
}
|
|
|
|
if (isset($this->ip) && isset($this->db_user) && isset($this->db_passwd)) {
|
|
try {
|
|
if (!isset($this->db_sourcename)) {
|
|
$this->db_sourcename = DB_NAME;
|
|
}
|
|
$value = 'none';
|
|
$sDataBase = 'database_' . strtolower(DB_ADAPTER);
|
|
if (G::LoadSystemExist($sDataBase)) {
|
|
$oDataBase = new database();
|
|
$value = $oDataBase->getServerVersion($driver, $this->ip, $this->db_port, $this->db_user, $this->db_passwd, $this->db_sourcename);
|
|
}
|
|
return $value;
|
|
} catch (Exception $e) {
|
|
throw new Exception($e->getMessage());
|
|
}
|
|
} else {
|
|
throw new Exception('NET::Error->No params for Data Base Server!');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* This function reurns DB name
|
|
*
|
|
* @param string $pAdapter
|
|
* @return void
|
|
*/
|
|
public function dbName($pAdapter)
|
|
{
|
|
switch ($pAdapter) {
|
|
case 'mysql':
|
|
return 'MySql';
|
|
break;
|
|
case 'pgsql':
|
|
return 'PostgreSQL';
|
|
break;
|
|
case 'mssql':
|
|
return 'Microsoft SQL Server';
|
|
break;
|
|
case 'oracle':
|
|
return 'Oracle';
|
|
break;
|
|
case 'informix':
|
|
return 'Informix';
|
|
break;
|
|
case 'sqlite':
|
|
return 'SQLite';
|
|
break;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* If there is an error then it shows
|
|
*
|
|
* @param string $pAdapter
|
|
* @return void
|
|
*/
|
|
public function showMsg()
|
|
{
|
|
if ($this->errno != 0) {
|
|
$msg = "
|
|
<center>
|
|
<fieldset style='width:90%'><legend>Class NET</legend>
|
|
<div align=left>
|
|
<font color='red'>
|
|
<b>NET::ERROR NO -> $this->errno<br/>
|
|
NET::ERROR MSG -> $this->errstr</b>
|
|
</font>
|
|
</div>
|
|
</fieldset>
|
|
<center>";
|
|
print($msg);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* This function gets an error
|
|
* param
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getErrno()
|
|
{
|
|
return $this->errno;
|
|
}
|
|
|
|
/**
|
|
* This function gets an error message
|
|
* param
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getErrmsg()
|
|
{
|
|
return $this->errstr;
|
|
}
|
|
}
|