yan/mdserver-web
1
0
Fork 0
mirror of https://github.com/midoks/mdserver-web.git synced 2026-10-18 23:45:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update sphinx_make.py

Browse Source
This commit is contained in:
Mr Chen
2024-05-19 17:27:22 +08:00
parent c90d752ae7
commit 8e47c73f5c
1 changed files with 16 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
plugins/sphinx/class/sphinx_make.py
+16 -22
View File
@@ -54,8 +54,7 @@ def pMysqlDb():
db.setPwd(pSqliteDb('config').where('id=?', (1,)).getField('mysql_root'))
return db
def getTablePk(db, table):
pdb = pMysqlDb()
def getTablePk(pdb, db, table):
# SHOW INDEX FROM bbs.bbs_ucenter_vars WHERE Key_name = 'PRIMARY'
pkey_sql = "SHOW INDEX FROM {}.{} WHERE Key_name = 'PRIMARY';".format(db,table,);
pkey_data = pdb.query(pkey_sql)
@@ -74,8 +73,7 @@ def getTablePk(db, table):
return ''
def getTableFieldStr(db, table):
pdb = pMysqlDb()
def getTableFieldStr(pdb, db, table):
sql = "select COLUMN_NAME,DATA_TYPE from information_schema.COLUMNS where `TABLE_SCHEMA`='{}' and `TABLE_NAME` = '{}';"
sql = sql.format(db,table,)
fields = pdb.query(sql)
@@ -113,16 +111,14 @@ indexer
conf = conf.replace("{$server_dir}", mw.getServerDir())
return conf
def makeSphinxDbSourceRangeSql(db, table):
pdb = pMysqlDb()
pkey_name = getTablePk(db, table)
def makeSphinxDbSourceRangeSql(pdb, db, table):
pkey_name = getTablePk(pdb, db, table)
sql = "SELECT min("+pkey_name+"), max("+pkey_name+") FROM "+table
return sql
def makeSphinxDbSourceQuerySql(db, table):
pdb = pMysqlDb()
pkey_name = getTablePk(db, table)
field_str = getTableFieldStr(db,table)
def makeSphinxDbSourceQuerySql(pdb, db, table):
pkey_name = getTablePk(pdb, db, table)
field_str = getTableFieldStr(pdb, db,table)
# print(field_str)
if pkey_name == 'id':
sql = "SELECT " + field_str + " FROM " + table + " where id >= $start AND id <= $end"
@@ -130,7 +126,7 @@ def makeSphinxDbSourceQuerySql(db, table):
sql = "SELECT "+pkey_name+' as id,' + field_str + " FROM " + table + " where id >= $start AND id <= $end"
return sql
def makeSphinxDbSource(db, table):
def makeSphinxDbSource(pdb, db, table):
db_info = pSqliteDb('databases').field('username,password').where('name=?', (db,)).find()
port = getDbPort()
@@ -172,13 +168,13 @@ index {$DB_NAME}_{$TABLE_NAME}
conf = conf.replace("{$DB_PASS}", db_info['password'])
conf = conf.replace("{$DB_PORT}", port)
range_sql = makeSphinxDbSourceRangeSql(db,table)
range_sql = makeSphinxDbSourceRangeSql(pdb, db, table)
conf = conf.replace("{$DB_RANGE_SQL}", range_sql)
query_sql = makeSphinxDbSourceQuerySql(db,table)
query_sql = makeSphinxDbSourceQuerySql(pdb, db,table)
conf = conf.replace("{$DB_QUERY_SQL}", query_sql)
sph_field = makeSqlToSphinxTable(db,table)
sph_field = makeSqlToSphinxTable(pdb, db,table)
conf = conf.replace("{$SPH_FIELD}", sph_field)
return conf
@@ -196,33 +192,31 @@ def makeSqlToSphinxAll():
dbname = dblist[x]['Database']
if mw.inArray(filter_db, dbname):
continue
conf += makeSqlToSphinxDb(dbname)
conf += makeSqlToSphinxDb(pdb, dbname)
return conf
def makeSqlToSphinxDb(db, table = []):
def makeSqlToSphinxDb(pdb, db, table = []):
conf = ''
pdb = pMysqlDb()
tables = pdb.query("show tables in "+ db)
for x in range(len(tables)):
key = 'Tables_in_'+db
table_name = tables[x][key]
pkey_name = getTablePk(db,table_name)
pkey_name = getTablePk(pdb, db, table_name)
if pkey_name == '':
continue
conf += makeSphinxDbSource(db,table_name)
conf += makeSphinxDbSource(pdb, db, table_name)
# print(conf)
# print(table_name+':'+pkey_name)
# db_field_str = makeSqlToSphinxTable(db,table_name)
# print(db_field_str)
return conf
def makeSqlToSphinxTable(db,table):
pdb = pMysqlDb()
def makeSqlToSphinxTable(pdb,db,table):
sql = "select COLUMN_NAME,DATA_TYPE from information_schema.COLUMNS where `TABLE_SCHEMA`='{}' and `TABLE_NAME` = '{}';"
sql = sql.format(db,table,)