mirror of
https://gitee.com/fastadminnet/framework.git
synced 2026-07-07 23:22:48 +08:00
完善数据库驱动
This commit is contained in:
@@ -41,11 +41,11 @@ class Oracle extends Builder
|
|||||||
}
|
}
|
||||||
return $limitStr ? ' WHERE ' . $limitStr : '';
|
return $limitStr ? ' WHERE ' . $limitStr : '';
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 设置锁机制
|
* 设置锁机制
|
||||||
* @access protected
|
* @access protected
|
||||||
* @param bool|false $lock
|
* @param bool|false $lock
|
||||||
*
|
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
protected function parseLock($lock = false)
|
protected function parseLock($lock = false)
|
||||||
|
|||||||
@@ -58,11 +58,11 @@ class Sqlsrv extends Builder
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* limit
|
* limit
|
||||||
* @access public
|
* @access protected
|
||||||
* @param mixed $limit
|
* @param mixed $limit
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
public function parseLimit($limit)
|
protected function parseLimit($limit)
|
||||||
{
|
{
|
||||||
if (empty($limit)) {
|
if (empty($limit)) {
|
||||||
return '';
|
return '';
|
||||||
|
|||||||
@@ -43,7 +43,7 @@ class Mysql extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据表的字段信息
|
* 取得数据表的字段信息
|
||||||
* @access public
|
* @access public
|
||||||
* @param $tableName
|
* @param string $tableName
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getFields($tableName)
|
public function getFields($tableName)
|
||||||
|
|||||||
@@ -96,9 +96,7 @@ class Oracle extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据表的字段信息
|
* 取得数据表的字段信息
|
||||||
* @access public
|
* @access public
|
||||||
*
|
* @param string $tableName
|
||||||
* @param $tableName
|
|
||||||
*
|
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getFields($tableName)
|
public function getFields($tableName)
|
||||||
|
|||||||
@@ -37,6 +37,7 @@ class Pgsql extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据表的字段信息
|
* 取得数据表的字段信息
|
||||||
* @access public
|
* @access public
|
||||||
|
* @param string $tableName
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getFields($tableName)
|
public function getFields($tableName)
|
||||||
@@ -46,6 +47,7 @@ class Pgsql extends Connection
|
|||||||
$info = [];
|
$info = [];
|
||||||
if ($result) {
|
if ($result) {
|
||||||
foreach ($result as $key => $val) {
|
foreach ($result as $key => $val) {
|
||||||
|
$val = array_change_key_case($val);
|
||||||
$info[$val['field']] = [
|
$info[$val['field']] = [
|
||||||
'name' => $val['field'],
|
'name' => $val['field'],
|
||||||
'type' => $val['type'],
|
'type' => $val['type'],
|
||||||
@@ -62,6 +64,7 @@ class Pgsql extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据库的表信息
|
* 取得数据库的表信息
|
||||||
* @access public
|
* @access public
|
||||||
|
* @param string $dbName
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getTables($dbName = '')
|
public function getTables($dbName = '')
|
||||||
|
|||||||
@@ -34,6 +34,7 @@ class Sqlite extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据表的字段信息
|
* 取得数据表的字段信息
|
||||||
* @access public
|
* @access public
|
||||||
|
* @param string $tableName
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getFields($tableName)
|
public function getFields($tableName)
|
||||||
@@ -43,6 +44,7 @@ class Sqlite extends Connection
|
|||||||
$info = [];
|
$info = [];
|
||||||
if ($result) {
|
if ($result) {
|
||||||
foreach ($result as $key => $val) {
|
foreach ($result as $key => $val) {
|
||||||
|
$val = array_change_key_case($val);
|
||||||
$info[$val['name']] = [
|
$info[$val['name']] = [
|
||||||
'name' => $val['name'],
|
'name' => $val['name'],
|
||||||
'type' => $val['type'],
|
'type' => $val['type'],
|
||||||
@@ -59,6 +61,7 @@ class Sqlite extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据库的表信息
|
* 取得数据库的表信息
|
||||||
* @access public
|
* @access public
|
||||||
|
* @param string $dbName
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getTables($dbName = '')
|
public function getTables($dbName = '')
|
||||||
|
|||||||
@@ -19,7 +19,6 @@ use think\db\Connection;
|
|||||||
*/
|
*/
|
||||||
class Sqlsrv extends Connection
|
class Sqlsrv extends Connection
|
||||||
{
|
{
|
||||||
protected $selectSql = 'SELECT T1.* FROM (SELECT thinkphp.*, ROW_NUMBER() OVER (%ORDER%) AS ROW_NUMBER FROM (SELECT %DISTINCT% %FIELD% FROM %TABLE%%JOIN%%WHERE%%GROUP%%HAVING%) AS thinkphp) AS T1 %LIMIT%%COMMENT%';
|
|
||||||
// PDO连接参数
|
// PDO连接参数
|
||||||
protected $options = [
|
protected $options = [
|
||||||
PDO::ATTR_CASE => PDO::CASE_LOWER,
|
PDO::ATTR_CASE => PDO::CASE_LOWER,
|
||||||
@@ -46,6 +45,7 @@ class Sqlsrv extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据表的字段信息
|
* 取得数据表的字段信息
|
||||||
* @access public
|
* @access public
|
||||||
|
* @param string $tableName
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getFields($tableName)
|
public function getFields($tableName)
|
||||||
@@ -61,6 +61,7 @@ class Sqlsrv extends Connection
|
|||||||
$info = [];
|
$info = [];
|
||||||
if ($result) {
|
if ($result) {
|
||||||
foreach ($result as $key => $val) {
|
foreach ($result as $key => $val) {
|
||||||
|
$val = array_change_key_case($val);
|
||||||
$info[$val['column_name']] = [
|
$info[$val['column_name']] = [
|
||||||
'name' => $val['column_name'],
|
'name' => $val['column_name'],
|
||||||
'type' => $val['data_type'],
|
'type' => $val['data_type'],
|
||||||
@@ -77,6 +78,7 @@ class Sqlsrv extends Connection
|
|||||||
/**
|
/**
|
||||||
* 取得数据表的字段信息
|
* 取得数据表的字段信息
|
||||||
* @access public
|
* @access public
|
||||||
|
* @param string $dbName
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
public function getTables($dbName = '')
|
public function getTables($dbName = '')
|
||||||
|
|||||||
Reference in New Issue
Block a user