server_common/tools
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add check_wid.php

Browse Source
This commit is contained in:
aozhiwei 2018-12-04 17:49:01 +08:00
parent 04a7e43960
commit 4edad03e7b
2 changed files with 158 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
scripts/build_wid/build_wid.py
View File

@ -82,13 +82,13 @@ def buildWid(databaseName):
finsh_flag = 1;
select_count = 0;
save_file_name = 'updata_wid.txt'
save_file_name = 'updata_wid_test.txt'
while select_count < 100 and finsh_flag:
min_idx = select_min_idx + select_count * 100
max_idx = select_max_idx + select_count * 100
min_idx = select_min_idx + select_count * 1000
max_idx = select_max_idx + select_count * 1000
select_info = getSelectInfo(min_idx,max_idx,database_config)
@ -117,4 +117,4 @@ def buildWid(databaseName):
return
buildWid('accountdb1')
buildWid('accountdb_bk1')

154
scripts/build_wid/check_wid.php Normal file
View File

@ -0,0 +1,154 @@
<?php
class Mysql
{
private $_host = '';
private $_port = 3306;
private $_user = '';
private $_passwd = '';
private $_dbname = '';
private $_conn = null;
private $_result = null;
public function __construct($configs){
$this->_host = $configs['host'];
$this->_user = $configs['user'];
$this->_passwd = $configs['passwd'];
$this->_dbname = $configs['dbname'];
$conn_str = sprintf("mysql:host=%s;port=%d;dbname=%s;charset=utf8",
$this->_host,
$this->_port,
$this->_dbname);
$this->_conn = new \PDO($conn_str,
$this->_user,
$this->_passwd
);
}
public function __destruct(){
$this->_conn = null;
}
public function execQuery($querystr, $params = null){
$params = $params ? $params : array();
$statement = $this->_conn->prepare($querystr);
$ret = $statement->execute($params);
if(!$ret){
error_log($statement->errorInfo()[2]);
die();
return null;
}else{
return $statement->fetchAll(\PDO::FETCH_ASSOC);
}
}
public function execQueryOne($querystr, $params = null){
$params = $params ? $params : array();
$statement = $this->_conn->prepare($querystr);
$ret = $statement->execute($params);
if(!$ret){
error_log($statement->errorInfo()[2]);
die();
return null;
}else{
$rows = $statement->fetchAll();
return count($rows) > 0 ? $rows[0] : null;
}
}
public function execQueryEx($querystr, $params, $condexper, $orderexper=null){
$params = $params ? $params : array();
$querystr = "SELECT * FROM ($querystr) a WHERE 1=1";
foreach($condexper as $fieldname=>$paramname){
if(array_key_exists($paramname, $_REQUEST) && $_REQUEST[$paramname] != ''){
$quoted_str = $this->_conn->quote('%' . $_REQUEST[$paramname] . '%');
$querystr = $querystr . " AND $fieldname LIKE $quoted_str";
}
}
if($orderexper && count($orderexper) > 0){
$querystr = $querystr . ' ORDER BY ';
foreach($orderexper as $expr){
$querystr = $querystr . " $expr[0] $expr[1],";
}
$querystr = substr($querystr, 0, strlen($querystr) - 1);
}
if(array_key_exists('start', $_REQUEST) && array_key_exists('limit', $_REQUEST)){
$querystr .= " LIMIT $_REQUEST[start], $_REQUEST[limit]";
}
// error_log($querystr);
$statement = $this->_conn->prepare($querystr);
$ret = $statement->execute($params);
if(!$ret){
error_log($statement->errorInfo()[2]);
}
return $statement->fetchAll(PDO::FETCH_ASSOC);
}
public function execQueryTotalCount($querystr, $params, $condexper, $orderexper){
$params = $params ? $params : array();
$querystr = "SELECT COUNT(*) FROM ($querystr) a WHERE 1=1";
foreach($condexper as $fieldname=>$paramname){
if(array_key_exists($paramname, $_REQUEST) && $_REQUEST[$paramname] != ''){
$quoted_str = $this->_conn->quote('%' . $_REQUEST[$paramname] . '%');
$querystr = $querystr . " AND $fieldname LIKE $quoted_str";
}
}
if($orderexper && count($orderexper) > 0){
$querystr = $querystr . ' ORDER BY ';
foreach($orderexper as $expr){
$querystr = $querystr . " $expr[0] $expr[1],";
}
$querystr = substr($querystr, 0, strlen($querystr) - 1);
}
$statement = $this->_conn->prepare($querystr);
$ret = $statement->execute($params);
if(!$ret){
error_log($statement->errorInfo()[2]);
die();
return -1;
}
$rows = $statement->fetchAll();
return count($rows) > 0 ? $rows[0][0] : -1;
}
public function execQueryPage($querystr, $params, $condexper, $orderexper, &$totalcount){
$totalcount = $this->execQueryTotalCount($querystr, $params, $condexper, $orderexper);
return $this->execQueryEx($querystr, $params, $condexper, $orderexper);
}
public function execQueryRowCount($querystr, $params = null){
$params = $params ? $params : array();
$statement = $this->_conn->prepare($querystr);
$ret = $statement->execute($params);
if(!$ret){
error_log($statement->errorInfo()[2]);
die();
}
return $statement->rowCount();
}
public function execScript($querystr, $params = null){
$params = $params ? $params : array();
$statement = $this->_conn->prepare($querystr);
$ret = $statement->execute($params);
if(!$ret){
error_log('execScript： ' . $statement->errorInfo()[2]);
die();
}
return $ret;
}
}
$conn = new Mysql(array(
'host' => '127.0.0.1',
'port' => 3306,
'user' => 'root',
'passwd' => 'keji178',
'dbname' => 'accountdb_bk1',
));
$row = $conn->execQueryOne('SELECT * FROM accounts LIMIT 1, 10');
var_dump($row);
echo "hello world!\n";