#-*- conding:utf-8 -*-
import requests,re,pymysql
from pyquery import PyQuery as pq
url_index = ['/news/cgnjj_{}.html'.format(pages) for pages in range(1,2)]
def index_content(url_index,title=0,time=0):
#print('起始页：' + url_index)
index_req = requests.get(url_index,timeout = 10)
index_req.encoding = 'utf-8'
index_content = index_req.text
content_url = re.findall('<div class="text text-no-img">.*?<p class="title">.*?<a href="(.*?)" target="_blank">',index_content,re.S)
title = re.search('<p class="title">.*?<a href=".*?" target="_blank">(.*?)</a>',index_content,re.S).group(1)
time = re.search('<p class="time">(.*?)</p>',index_content,re.S).group(1).replace("年", "-").replace("月", "-").replace("日", "")
#time = time_content
#re.sub(".", "", title)
#print('标题：' + title)
#print('时间：' + time)
return content_url
def content(content_url):
content_req = requests.get(content_url,timeout = 10)
content_req.encoding = 'utf-8'
content = content_req.text
title = re.search('<h1>(.*?)</h1>',content,re.S).group(1)
time = re.search('<div class="time">(.*?)</div>',content,re.S).group(1).replace("年", "-").replace("月", "-").replace("日", "")
sources = re.search('<div class="source">.*?<span>来源：</span>(.*?)</div>',content,re.S).group(1)
content_content = re.search('<!--文章主体-->(.*?)<!--责任编辑-->',content,re.S).group(1)
pic = re.findall('''.*?src="(.*?)"''',content_content,re.S)#.sub('.*?same.*?','',content_content)
content_body = {'title:':title,
'time:':time,
'source:':sources,
'content:':content_content,
'pic:':pic
}
#print('网址：' + content_url)
#print ('标题：' + title)
#print ('时间：' + time)
#print ('来源:' + source)
#print ('内容：' + content_content )
#print (pic)
print(type(title))
return content_body
def save_sql(content_body):
try:
db = pymysql.connect("localhost","root","root","test" )
cursor = db.cursor()
#sql = """INSERT INTO test(title,source_time, source, content_body, pageurl,pic)VALUES (title,time,source,content_content,content_url,pic)"""
# 执行sql语句
sql = """INSERT INTO test(title,source_time, sources, content_body, pageurl,pic)VALUES (%s,%s,%s,%s,%s,%s)"""
# 执行 sql 语句
cursor.execute(sql,(title,time,sources,content_content,content_url,pic))
#cursor.execute(sql)
# 提交到数据库执行
mit()
except:
# 如果发生错误则回滚
db.rollback()
# 关闭数据库连接
db.close()
def save_csv(con):
with open('C:\\Users\\Administrator\\Desktop\\finance.csv','wb+') as f: #wb为以二进制方式打开
con = str.encode('utf-8')
f.write(con)
f.close()
for url_list in url_index:
content_url = index_content(url_list,title=0,time=0)
for con_url in content_url:
cons = content(con_url)
print(cons)
save_sql(cons)
#for con in cons:
# #print(con)
# save_csv(con)
#save_sql(con)
mysql点保存没反应_保存到mysql数据库没反应 打印时正常的但是没插入任何数据 写入文件也没用...
