parent
0d2d9f2225
commit
181d116b38
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,76 @@
|
|||||||
|
import pymysql
|
||||||
|
|
||||||
|
# 打开数据库连接
|
||||||
|
meituanDb = pymysql.connect("121.36.100.63","mkl","010512", "meituan" )
|
||||||
|
|
||||||
|
# 使用 cursor() 方法创建一个游标对象 cursor
|
||||||
|
cursor = meituanDb.cursor()
|
||||||
|
|
||||||
|
lists = [ "attractions", "entertainment", "food", "hotel", "sport" ]
|
||||||
|
|
||||||
|
try:
|
||||||
|
results = []
|
||||||
|
for string in lists:
|
||||||
|
# 执行SQL语句
|
||||||
|
cursor.execute("SELECT * FROM %s"%string)
|
||||||
|
# 获取所有记录列表
|
||||||
|
results.append(cursor.fetchall())
|
||||||
|
print (string + " loading over")
|
||||||
|
meituanDb.close()
|
||||||
|
|
||||||
|
listDb = pymysql.connect("121.36.100.63","mkl","010512", "list" )
|
||||||
|
cursor = listDb.cursor()
|
||||||
|
cursor.execute("DELETE FROM favorablelist")
|
||||||
|
listDb.commit()
|
||||||
|
items = []
|
||||||
|
maxSize = 10
|
||||||
|
n = 0
|
||||||
|
|
||||||
|
k = 0
|
||||||
|
while ( k < 5 ):
|
||||||
|
for row in results[k]:
|
||||||
|
if ( k == 0 ):
|
||||||
|
item = [ row[0], row[1], row[8], row[4], row[5], row[2] ]
|
||||||
|
elif ( k == 1 ):
|
||||||
|
item = [ row[0], row[1], row[9], row[4], row[6], row[2] ]
|
||||||
|
elif ( k == 2 ):
|
||||||
|
item = [ row[0], row[1], row[8], row[4], row[5], row[2] ]
|
||||||
|
elif ( k == 3 ):
|
||||||
|
item = [ row[0], row[1], row[8], row[3], row[5], row[2] ]
|
||||||
|
elif ( k == 4 ):
|
||||||
|
item = [ row[0], row[1], row[9], row[4], row[6], row[2] ]
|
||||||
|
i = 0
|
||||||
|
isIn = False
|
||||||
|
while ( i < n ):
|
||||||
|
if ( items[i][5] == item[5] ):
|
||||||
|
isIn = True
|
||||||
|
i += 1
|
||||||
|
if (isIn):
|
||||||
|
continue
|
||||||
|
if ( n < maxSize ):
|
||||||
|
items.append(item)
|
||||||
|
n += 1
|
||||||
|
else:
|
||||||
|
i = 0
|
||||||
|
while ( i < n ):
|
||||||
|
if ( float(item[3]) * float(item[4]) > float(items[i][3]) * float(items[i][4]) ):
|
||||||
|
items[i] = item
|
||||||
|
break
|
||||||
|
i += 1
|
||||||
|
k += 1
|
||||||
|
print ("add over")
|
||||||
|
|
||||||
|
cursor = listDb.cursor()
|
||||||
|
i = 0
|
||||||
|
while (i < n):
|
||||||
|
listSql = """INSERT INTO favorablelist(id,
|
||||||
|
url, cateId, score, title) """
|
||||||
|
cursor.execute(listSql + "VALUES(%d, '%s', '%s', %f, '%s')"%(items[i][0], items[i][1], items[i][2], float(items[i][3]) * float(items[i][4]), items[i][5]))
|
||||||
|
listDb.commit()
|
||||||
|
i += 1
|
||||||
|
print ("insert over")
|
||||||
|
|
||||||
|
except:
|
||||||
|
listDb.rollback()
|
||||||
|
|
||||||
|
listDb.close()
|
@ -0,0 +1,76 @@
|
|||||||
|
import pymysql
|
||||||
|
|
||||||
|
# 打开数据库连接
|
||||||
|
meituanDb = pymysql.connect("121.36.100.63","mkl","010512", "meituan" )
|
||||||
|
|
||||||
|
# 使用 cursor() 方法创建一个游标对象 cursor
|
||||||
|
cursor = meituanDb.cursor()
|
||||||
|
|
||||||
|
lists = [ "attractions", "entertainment", "food", "hotel", "sport" ]
|
||||||
|
|
||||||
|
try:
|
||||||
|
results = []
|
||||||
|
for string in lists:
|
||||||
|
# 执行SQL语句
|
||||||
|
cursor.execute("SELECT * FROM %s WHERE comments < 500"%string)
|
||||||
|
# 获取所有记录列表
|
||||||
|
results.append(cursor.fetchall())
|
||||||
|
print (string + " loading over")
|
||||||
|
meituanDb.close()
|
||||||
|
|
||||||
|
listDb = pymysql.connect("121.36.100.63","mkl","010512", "list" )
|
||||||
|
cursor = listDb.cursor()
|
||||||
|
cursor.execute("DELETE FROM minoritylist")
|
||||||
|
listDb.commit()
|
||||||
|
items = []
|
||||||
|
maxSize = 10
|
||||||
|
n = 0
|
||||||
|
|
||||||
|
k = 0
|
||||||
|
while ( k < 5 ):
|
||||||
|
for row in results[k]:
|
||||||
|
if ( k == 0 ):
|
||||||
|
item = [ row[0], row[1], row[8], row[4], row[5], row[2] ]
|
||||||
|
elif ( k == 1 ):
|
||||||
|
item = [ row[0], row[1], row[9], row[4], row[6], row[2] ]
|
||||||
|
elif ( k == 2 ):
|
||||||
|
item = [ row[0], row[1], row[8], row[4], row[5], row[2] ]
|
||||||
|
elif ( k == 3 ):
|
||||||
|
item = [ row[0], row[1], row[8], row[3], row[5], row[2] ]
|
||||||
|
elif ( k == 4 ):
|
||||||
|
item = [ row[0], row[1], row[9], row[4], row[6], row[2] ]
|
||||||
|
i = 0
|
||||||
|
isIn = False
|
||||||
|
while ( i < n ):
|
||||||
|
if ( items[i][5] == item[5] ):
|
||||||
|
isIn = True
|
||||||
|
i += 1
|
||||||
|
if (isIn):
|
||||||
|
continue
|
||||||
|
if ( n < maxSize ):
|
||||||
|
items.append(item)
|
||||||
|
n += 1
|
||||||
|
else:
|
||||||
|
i = 0
|
||||||
|
while ( i < n ):
|
||||||
|
if ( float(item[3]) * float(item[4]) > float(items[i][3]) * float(items[i][4]) ):
|
||||||
|
items[i] = item
|
||||||
|
break
|
||||||
|
i += 1
|
||||||
|
k += 1
|
||||||
|
print ("add over")
|
||||||
|
|
||||||
|
cursor = listDb.cursor()
|
||||||
|
i = 0
|
||||||
|
while (i < n):
|
||||||
|
listSql = """INSERT INTO minoritylist(id,
|
||||||
|
url, cateId, score, title) """
|
||||||
|
cursor.execute(listSql + "VALUES(%d, '%s', '%s', %f, '%s')"%(items[i][0], items[i][1], items[i][2], float(items[i][3]) * float(items[i][4]), items[i][5]))
|
||||||
|
listDb.commit()
|
||||||
|
i += 1
|
||||||
|
print ("insert over")
|
||||||
|
|
||||||
|
except:
|
||||||
|
listDb.rollback()
|
||||||
|
|
||||||
|
listDb.close()
|
After Width: | Height: | Size: 197 KiB |
After Width: | Height: | Size: 44 KiB |
After Width: | Height: | Size: 929 B |
After Width: | Height: | Size: 197 KiB |
Loading…
Reference in new issue