Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class Mysql():
- def __init__(self, host='localhost', username='root', password='', database=''):
- try:
- self.db = mysql.connect(host, username, password, database, charset="utf8")
- self.cursor = self.db.cursor()
- except mysql.DatabaseError as error:
- print error
- def insert_data(self, table_name, data):
- keys = ", ".join(data.keys())
- values = ", ".join(['%s'] * len(data))
- sql_query = "insert into %s (%s) values (%s)" % (table_name, keys, values)
- try:
- self.cursor.execute(sql_query, data.values())
- self.db.commit()
- except mysql.DatabaseError as error:
- print format(error)
- self.db.rollback()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement