mirror of
https://github.com/midoks/mdserver-web.git
synced 2026-10-18 23:45:52 +08:00
Update index.py
This commit is contained in:
+1
-137
@@ -133,146 +133,10 @@ def initDreplace():
|
|||||||
if not os.path.exists(log_path):
|
if not os.path.exists(log_path):
|
||||||
os.mkdir(log_path)
|
os.mkdir(log_path)
|
||||||
|
|
||||||
return file_bin
|
return ''
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def getSshPort():
|
|
||||||
content = mw.readFile(getConf())
|
|
||||||
rep = r'SSH_PORT\s*=\s*(.*)'
|
|
||||||
tmp = re.search(rep, content)
|
|
||||||
if not tmp:
|
|
||||||
return ''
|
|
||||||
return tmp.groups()[0]
|
|
||||||
|
|
||||||
|
|
||||||
def getHttpPort():
|
|
||||||
content = mw.readFile(getConf())
|
|
||||||
rep = r'HTTP_PORT\s*=\s*(.*)'
|
|
||||||
tmp = re.search(rep, content)
|
|
||||||
if not tmp:
|
|
||||||
return ''
|
|
||||||
return tmp.groups()[0]
|
|
||||||
|
|
||||||
|
|
||||||
def getRootPath():
|
|
||||||
content = mw.readFile(getConf())
|
|
||||||
rep = r'ROOT\s*=\s*(.*)'
|
|
||||||
tmp = re.search(rep, content)
|
|
||||||
if not tmp:
|
|
||||||
return ''
|
|
||||||
return tmp.groups()[0]
|
|
||||||
|
|
||||||
|
|
||||||
def getDbConfValue():
|
|
||||||
conf = getConf()
|
|
||||||
if not os.path.exists(conf):
|
|
||||||
return {}
|
|
||||||
|
|
||||||
content = mw.readFile(conf)
|
|
||||||
rep_scope = r"\[database\](.*?)\["
|
|
||||||
tmp = re.findall(rep_scope, content, re.S)
|
|
||||||
|
|
||||||
rep = '(\\w*)\\s*=\\s*(.*)'
|
|
||||||
tmp = re.findall(rep, tmp[0])
|
|
||||||
r = {}
|
|
||||||
for x in range(len(tmp)):
|
|
||||||
k = tmp[x][0]
|
|
||||||
v = tmp[x][1]
|
|
||||||
r[k] = v
|
|
||||||
return r
|
|
||||||
|
|
||||||
|
|
||||||
def pMysqlDb(conf):
|
|
||||||
host = conf['HOST'].split(':')
|
|
||||||
# pymysql
|
|
||||||
db = mw.getMyORM()
|
|
||||||
# MySQLdb |
|
|
||||||
# db = mw.getMyORMDb()
|
|
||||||
|
|
||||||
db.setPort(int(host[1]))
|
|
||||||
db.setUser(conf['USER'])
|
|
||||||
|
|
||||||
if 'PASSWD' in conf:
|
|
||||||
db.setPwd(conf['PASSWD'])
|
|
||||||
else:
|
|
||||||
db.setPwd(conf['PASSWORD'])
|
|
||||||
|
|
||||||
db.setDbName(conf['NAME'])
|
|
||||||
# db.setSocket(getSocketFile())
|
|
||||||
db.setCharset("utf8")
|
|
||||||
return db
|
|
||||||
|
|
||||||
|
|
||||||
def pSqliteDb(conf):
|
|
||||||
# print(conf)
|
|
||||||
import db
|
|
||||||
psDb = db.Sql()
|
|
||||||
|
|
||||||
# 默认
|
|
||||||
gsdir = getServerDir() + '/data'
|
|
||||||
dbname = 'gitea'
|
|
||||||
if conf['PATH'][0] == '/':
|
|
||||||
# 绝对路径
|
|
||||||
pass
|
|
||||||
else:
|
|
||||||
path = conf['PATH'].split('/')
|
|
||||||
gsdir = getServerDir() + '/' + path[0]
|
|
||||||
dbname = path[1].split('.')[0]
|
|
||||||
|
|
||||||
# print(gsdir, dbname)
|
|
||||||
psDb.dbPos(gsdir, dbname)
|
|
||||||
return psDb
|
|
||||||
|
|
||||||
|
|
||||||
def getGiteaDbType(conf):
|
|
||||||
|
|
||||||
if 'DB_TYPE' in conf:
|
|
||||||
return conf['DB_TYPE']
|
|
||||||
|
|
||||||
if 'TYPE' in conf:
|
|
||||||
return conf['TYPE']
|
|
||||||
|
|
||||||
return 'NONE'
|
|
||||||
|
|
||||||
|
|
||||||
def pQuery(sql):
|
|
||||||
conf = getDbConfValue()
|
|
||||||
gtype = getGiteaDbType(conf)
|
|
||||||
if gtype == 'sqlite3':
|
|
||||||
db = pSqliteDb(conf)
|
|
||||||
data = db.query(sql, []).fetchall()
|
|
||||||
return data
|
|
||||||
elif gtype == 'mysql':
|
|
||||||
db = pMysqlDb(conf)
|
|
||||||
return db.query(sql)
|
|
||||||
|
|
||||||
print("仅支持mysql|sqlite3配置")
|
|
||||||
exit(0)
|
|
||||||
|
|
||||||
|
|
||||||
def isSqlError(mysqlMsg):
|
|
||||||
# 检测数据库执行错误
|
|
||||||
_mysqlMsg = str(mysqlMsg)
|
|
||||||
# print _mysqlMsg
|
|
||||||
if "MySQLdb" in _mysqlMsg:
|
|
||||||
return mw.returnData(False, 'MySQLdb组件缺失! <br>进入SSH命令行输入: pip install mysql-python')
|
|
||||||
if "2002," in _mysqlMsg:
|
|
||||||
return mw.returnData(False, '数据库连接失败,请检查数据库服务是否启动!')
|
|
||||||
if "using password:" in _mysqlMsg:
|
|
||||||
return mw.returnData(False, '数据库管理密码错误!')
|
|
||||||
if "Connection refused" in _mysqlMsg:
|
|
||||||
return mw.returnData(False, '数据库连接失败,请检查数据库服务是否启动!')
|
|
||||||
if "1133," in _mysqlMsg:
|
|
||||||
return mw.returnData(False, '数据库用户不存在!')
|
|
||||||
if "1007," in _mysqlMsg:
|
|
||||||
return mw.returnData(False, '数据库已经存在!')
|
|
||||||
if "1044," in _mysqlMsg:
|
|
||||||
return mw.returnData(False, mysqlMsg[1])
|
|
||||||
if "2003," in _mysqlMsg:
|
|
||||||
return mw.returnData(False, "Can't connect to MySQL server on '127.0.0.1' (61)")
|
|
||||||
return mw.returnData(True, 'OK')
|
|
||||||
|
|
||||||
|
|
||||||
def appOp(method):
|
def appOp(method):
|
||||||
initDreplace()
|
initDreplace()
|
||||||
|
|||||||
Reference in New Issue
Block a user