1

I'm trying to add multiple rows from a JSON object into MySQL but only the last row is added to the database. Is there a solution like "for each row"?

import requests
import json
import pymysql
import urllib.request

con = pymysql.connect(host = 'host', port = 3306, user = 'user', passwd = 'pass', db = 'db')
cursor = con.cursor()
url = 'url to json'
urllib.request.urlopen(url).read()
response = urllib.request.urlopen(url).read()
json_obj = str(response, 'utf-8')
json_obj = json.loads(response.decode('utf-8'))

for obj in json_obj:
    print(obj["one"])
    print(obj["two"])
    print(obj["three"])
    print(obj["four"])
    print(obj["five"])
    print(obj["six"])
    print(obj["seven"])

cursor.execute("INSERT INTO test (one, two, three, four, five, six, seven) VALUES (%s,%s,%s,%s,%s,%s,%s)", (obj["one"], obj["two"], obj["three"], obj["four"], obj["five"], obj["six"], obj["seven"]))

con.commit()
con.close()

The JSON object looks like this and can hold between 5 and 50 records at once

[{"one":"1.232.123","two":"test","three":1242,"four":"2,4","five":"test","six":"test","seven":"test"},{"one":"3.322.876","two":"test","three":1312,"four":"3,4","five":"test","six":"test","seven":"test"},{"one":"1.232.123","two":"test","three":1242,"four":"2,4","five":"test","six":"test","seven":"test"},{"one":"3.322.876","two":"test","three":1312,"four":"3,4","five":"test","six":"test","seven":"test"}]

2 Answers 2

4

Error in indent in cursor.execute. Here is fixed code

import requests
import json
import pymysql
import urllib.request

con = pymysql.connect(host = 'host', port = 3306, user = 'user', passwd = 'pass', db = 'db')
cursor = con.cursor()
url = 'url to json'
urllib.request.urlopen(url).read()
response = urllib.request.urlopen(url).read()
json_obj = str(response, 'utf-8')
json_obj = json.loads(response.decode('utf-8'))

for obj in json_obj:
    print(obj["one"])
    print(obj["two"])
    print(obj["three"])
    print(obj["four"])
    print(obj["five"])
    print(obj["six"])
    print(obj["seven"])

    cursor.execute("INSERT INTO test (one, two, three, four, five, six, seven) VALUES (%s,%s,%s,%s,%s,%s,%s)", (obj["one"], obj["two"], obj["three"], obj["four"], obj["five"], obj["six"], obj["seven"]))

con.commit()
con.close()
Sign up to request clarification or add additional context in comments.

Comments

1

You should put your INSERT statement inside the for loop:

for obj in json_obj:
    print(obj["one"])
    print(obj["two"])
    print(obj["three"])
    print(obj["four"])
    print(obj["five"])
    print(obj["six"])
    print(obj["seven"])

    cursor.execute("INSERT INTO test (one, two, three, four, five, six, seven) VALUES (%s,%s,%s,%s,%s,%s,%s)", (obj["one"], obj["two"], obj["three"], obj["four"], obj["five"], obj["six"], obj["seven"]))

Comments

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.