exam_json_db.py

import json
import mysql.connector

db_connection = mysql.connector.connect(
    host = "localhost",
    user = "root",
    passwd = "",
    database = "schooldb"
)

found = False

# no error!
print('Database is connected successfully!')

mycursor = db_connection.cursor()

mycursor = db_connection.cursor()
mycursor.execute("CREATE TABLE  IF NOT EXISTS examtb(id int primary key auto_increment, question text not null, option1 text not null, option2 text not null, option3 text not null, correct_ans text not null)")


mycursor.execute("SHOW TABLES")
for row in mycursor:
    #print(row)
    if row[0] == 'examtb':
        print('Table created successfully')
        found = True

if not found:
    print('Table creation fails')
    exit(1)

with open('q.json','r') as qfile:
    questions = json.load(qfile)
    for quest in questions:
        sql = "INSERT INTO examtb(question,option1,option2,option3,correct_ans) values (%s,%s,%s,%s,%s)"
        params = (quest['question'],quest['option1'],quest['option2'],quest['option3'],quest['correct_ans'])
        mycursor.execute(sql,params)
        db_connection.commit()




mycursor.execute("SELECT * FROM examtb")
for row in mycursor:
    print(row)



mycursor.close()
db_connection.close()