python爬虫存进数据库

系统 1568 0
            
              
                import
              
               os
              
                ,
              
              sys

              
                import
              
               requests

              
                import
              
               bs4

              
                import
              
               pymysql

              
                #import MySQLdb
              
              
                #连接MYSQL数据库  ,第一个参数是ip地址/数据库的用户名/密码/数据库名称/端口/编码格式
              
              
db 
              
                =
              
               pymysql
              
                .
              
              connect
              
                (
              
              host
              
                =
              
              
                '127.0.0.1'
              
              
                ,
              
              user
              
                =
              
              
                'root'
              
              
                ,
              
              password
              
                =
              
              
                'mysql'
              
              
                ,
              
              db
              
                =
              
              
                'test'
              
              
                ,
              
              port
              
                =
              
              
                3306
              
              
                ,
              
              charset
              
                =
              
              
                'utf8'
              
              
                )
              
              
                #db = MySQLdb.connect('127.0.0.1','root','mysql','test',coon.set_character_set('utf8'))
              
              
                print
              
              
                (
              
              
                '连接数据库成功!'
              
              
                )
              
              
conn 
              
                =
              
               db
              
                .
              
              cursor
              
                (
              
              
                )
              
              
                #cursor是游标对象,获取指针以操作数据库
              
              
conn
              
                .
              
              execute
              
                (
              
              
                'set names utf8'
              
              
                )
              
              
                #-------------------------------------------------------------------------------------
              
              
html 
              
                =
              
              
                'https://www.dongmanmanhua.cn/dailySchedule?weekday=MONDAY'
              
              
result 
              
                =
              
               requests
              
                .
              
              get
              
                (
              
              html
              
                )
              
              
texts 
              
                =
              
               result
              
                .
              
              text

data 
              
                =
              
               bs4
              
                .
              
              BeautifulSoup
              
                (
              
              texts
              
                ,
              
              
                'html.parser'
              
              
                )
              
              
                ;
              
              
lidata 
              
                =
              
               data
              
                .
              
              select
              
                (
              
              
                'div#dailyList ul.daily_card li'
              
              
                )
              
              
                #print(lidata)
              
              
arr 
              
                =
              
              
                {
              
              
                }
              
              
                for
              
               x 
              
                in
              
               lidata
              
                :
              
              
    did 
              
                =
              
               x
              
                .
              
              get
              
                (
              
              
                'data-title-no'
              
              
                )
              
              
                print
              
              
                (
              
              did
              
                )
              
              
    name 
              
                =
              
               x
              
                .
              
              select
              
                (
              
              
                'p.subj'
              
              
                )
              
              
    name1 
              
                =
              
               name
              
                [
              
              
                0
              
              
                ]
              
              
                .
              
              get_text
              
                (
              
              
                )
              
              
    url 
              
                =
              
               x
              
                .
              
              a
              
                .
              
              get
              
                (
              
              
                'href'
              
              
                )
              
              
                #print(url)
              
              
    story 
              
                =
              
               x
              
                .
              
              a
              
                .
              
              p
    story1 
              
                =
              
               story
              
                .
              
              string
    user 
              
                =
              
               x
              
                .
              
              select
              
                (
              
              
                'p.author'
              
              
                )
              
              
    user1 
              
                =
              
               user
              
                [
              
              
                0
              
              
                ]
              
              
                .
              
              get_text
              
                (
              
              
                )
              
              
    like 
              
                =
              
               x
              
                .
              
              select
              
                (
              
              
                'em.grade_num'
              
              
                )
              
              
    like1 
              
                =
              
               like
              
                [
              
              
                0
              
              
                ]
              
              
                .
              
              get_text
              
                (
              
              
                )
              
              
                #-----------------------------------------------------------------------------------------------
              
              
                #写入MYSQL数据库
              
              
    t 
              
                =
              
              
                [
              
              did
              
                ,
              
              name1
              
                ,
              
              url
              
                ,
              
              story1
              
                ,
              
              user1
              
                ,
              
              like1
              
                ]
              
              
    sql 
              
                =
              
               u
              
                "INSERT INTO dongman(did,name,url,story,user,likes) VALUES(%s,%s,%s,%s,%s,%s)"
              
              
    conn
              
                .
              
              execute
              
                (
              
              sql
              
                ,
              
              t
              
                )
              
              
                #    t1 = (did,name1,url,story1,user1,like1)
              
              
                #    sql1 = u'''insert into dongman(did,name,url,story,user,likes) values (%d,'%s','%s','%s','%s','%s')''' % t1
              
              
                #    conn.execute(sql1)
              
              
    db
              
                .
              
              commit
              
                (
              
              
                )
              
              
                #提交操作
              
              
                print
              
              
                (
              
              
                '插入数据成功!'
              
              
                )
              
              
                #关闭MySQL连接
              
              
conn
              
                .
              
              close
              
                (
              
              
                )
              
              
db
              
                .
              
              close
              
                (
              
              
                )
              
            
          

更多文章、技术交流、商务合作、联系博主

微信扫码或搜索:z360901061

微信扫一扫加我为好友

QQ号联系: 360901061

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描下面二维码支持博主2元、5元、10元、20元等您想捐的金额吧,狠狠点击下面给点支持吧,站长非常感激您!手机微信长按不能支付解决办法:请将微信支付二维码保存到相册,切换到微信,然后点击微信右上角扫一扫功能,选择支付二维码完成支付。

【本文对您有帮助就好】

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描上面二维码支持博主2元、5元、10元、自定义金额等您想捐的金额吧,站长会非常 感谢您的哦!!!

发表我的评论
最新评论 总共0条评论