import pymysql

# 打开数据库连接 没有密码就不填写了passwd=''
db = pymysql.connect(host="localhost",port=3306, user="root")
 
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
 
# 使用 execute()  方法执行 SQL 查询 
sql="select schema_name from information_schema.schemata"

cursor.execute(sql)
 
# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()
 
print ("Databases: %s " % data)
 
# 关闭数据库连接
cursor.close()
db.close()

import requests
import re
import json
from requests.exceptions import RequestException
import time 

headers = {'User-Agent':'Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/63.0.3239.132 Safari/537.36'}
def get_one_page(url):
    try:
        res = requests.get(url, headers=headers)
        if res.status_code == 200:
            return res.text
        return None
    except RequestException:
        return None
def urls():
    return ['https://movie.douban.com/top250?start={}&filter='.format(str(i)) for i in range(0,250,25)]


key = []
p1 = '<span class="title">(.*?)</span>'
p2 = '''导[\u4e00-\u9fa5].*'''

def get_movie_name(p):
    key = []
    for url in urls():
        key += re.findall(p1, get_one_page(url))
    for k in key:
        if "&" in k:
            key.remove(k)
    return key
    
def get_movie_info(p):
    key = []
    info = []
    for url in urls():
        key += re.findall(p, get_one_page(url))
    
    for i in key:
        info += str(i[:-7].replace("&nbsp;"," "))
    
    return info

movie_name = get_movie_name(p1)
movie_info = get_movie_info(p2)

import pymysql

# 打开数据库连接
db = pymysql.connect(host="localhost",port=3306, user="root", db='test1')
 
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

for mn in movie_name:
    sql = "insert into movie (name) VALUES ('%s')" % (mn)
    print(sql)
    # 使用 execute()  方法执行 SQL 查询 
    cursor.execute(sql)

#使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()
 
print ("Databases : %s " % data)
 
# 关闭数据库连接
db.commit()