pythonからmysqlの操作（insert）がわからない

Question

前提・実現したいこと

twitterAPIを使いツイートを取得し、mysqlに入れたいのですが、insertの書き方が分かりません。
config.py には各々のキーを書いています

該当のソースコード

from requests_oauthlib import OAuth1Session
import json, config
import mysql.connector

CK = config.CONSUMER_KEY
CS = config.CONSUMER_SECRET_KEY
AT = config.ACCESS_TOKEN
ATS = config.ACCESS_TOKEN_SECRET

twitter = OAuth1Session(CK, CS, AT, ATS)

url = "https://api.twitter.com/1.1/search/tweets.json"

keyword = input('>> ')

params = {'q': keyword, 'count': 100}

for i in params:
    req = twitter.get(url, params=params)

    if req.status_code == 200:
        search_timeline = json.loads(req.text)
        for tweet in search_timeline['statuses']:
            print(tweet['user']['name'] + '::' + tweet['text'])
            print(tweet['created_at'])

    else:
        print("ERROR: %d" % req.status_code)


connection = mysql.connector.connect(db="twitter")
cursor = connection.cursor()
cursor.execute("CREATE TABLE justatest (name TEXT, content TEXT)")

data = []
for i in data:

  cur.execute("INSERt INTO justatest(name,content) VALUES  ・・・？

Comments

[papinianus]

pythonでインデントが死んでるのはつらすぎるので、質問を編集して、「<code>」ボタンを押してからコードをコピペしてください。dataが空に見える(得たtweetをpushしてない)ので、今できている最前線のコードにあらためていただくこともお願いします。

[lasagna0209]

質問を編集しました。2つ目の修正依頼はデータに変数を使えということでしょうか。
変数の概念はわかるのですが、この場合の使い方がわからないのでそこも含めて教えていただきたいです。
至らない点多々あり申し訳ございません

[gh640]

コードはご自身で書かれたものですか？拝見するかぎり変数の使い方がおわかりになっていないようには見えませんが、何がわからない感じでしょう。

[gh640]

ご質問の主旨である「 insert の書き方」については https://dev.mysql.com/doc/connector-python/en/connector-python-example-cursor-transaction.html で説明されているので、こちらがご参考になるかと思います。いかがでしょう。

[lasagna0209]

自分で書いたものです。
分からない部分はやはりinsert部分です。公式ドキュメントでは入れるデータを変数data_employee,data_salaryと一つずつ定義していますが、そうではなく、今回のように100件のツイートを一斉にやるやり方が分かりません。

Answer 1

ご回答いただきありがとうございます。 1 件ずつ挿入する方法はわかるけれど複数件まとめて挿入する方法がわからない、ということですかね。

メソッドは executemany() というものを使って、 data の各要素はタプルにしておくとよいのではないかと思います。

• MySQL :: MySQL Connector/Python Developer Guide :: 10.5.5 MySQLCursor.executemany() Method

次のようなコードにするとよいのではないでしょうか（私の手元では動作確認していないのでアイデアだけ参考にしていただければと思います）。

from requests_oauthlib import OAuth1Session
import json, config
import mysql.connector

CK = config.CONSUMER_KEY
CS = config.CONSUMER_SECRET_KEY
AT = config.ACCESS_TOKEN
ATS = config.ACCESS_TOKEN_SECRET

twitter = OAuth1Session(CK, CS, AT, ATS)

url = "https://api.twitter.com/1.1/search/tweets.json"

keyword = input('>> ')

params = {'q': keyword, 'count': 100}

# 変更点 1: data を for ループ前に移動
data = []
for i in params:
    req = twitter.get(url, params=params)

    if req.status_code == 200:
        search_timeline = json.loads(req.text)
        for tweet in search_timeline['statuses']:

            # 変更点 2: tweet の中身のうち、 name と content(text) を data に追加
            record = (tweet['user']['name'], tweet['text'])
            data.append(record)
            print(tweet['user']['name'] + '::' + tweet['text'])
            print(tweet['created_at'])

    else:
        print("ERROR: %d" % req.status_code)


connection = mysql.connector.connect(db="twitter")
cursor = connection.cursor()
cursor.execute("CREATE TABLE justatest (name TEXT, content TEXT)")

# 変更点 3: 前の for ループで蓄積した data をまとめて挿入
cursor.executemany("INSERT INTO justatest (name, content) VALUES (%s, %s)", data)

（変数 record はロジックをわかりやすくするために使っていますが、実際には data.append() にタプルを直接追加していただくとよいかと思います）