MySQL Connector/Python for Python 3.3_MySQL

python

import mysql.connector
import sys, os
 
user = 'root'
pwd  = '123456'
host = 'local.dba.tt'
db   = 'test'
 
data_file = 'mysql-test.dat'
 
create_table_sql = "create table if not exists mytable ( /
                    id int(10) auto_increment primary key, /
            name varchar(20), age int(4) ) /
            character set utf8"
 
insert_sql = "insert into mytable(name, age) values ('jay', 22 ), ('杰', 26)"
select_sql = "select id, name, age from mytable"
 
cnx = mysql.connector.connect(user=user, password=pwd, host=host, database=db)
cursor = cnx.cursor()
 
try:
    cursor.execute(create_table_sql)
except mysql.connector.error as err:
    print("create table 'mytable' failed.")
    print("error: {}".format(err.msg))
    sys.exit()
 
try:
    cursor.execute(insert_sql)
except mysql.connector.error as err:
    print("insert table 'mytable' failed.")
    print("error: {}".format(err.msg))
    sys.exit()
 
if os.path.exists(data_file):
    myfile = open(data_file)
    lines = myfile.readlines()
    myfile.close()
 
    for line in lines:
        myset = line.split()
        sql = "insert into mytable (name, age) values ('{}', {})".format(myset[0], myset[1])
        try:
            cursor.execute(sql)
        except mysql.connector.error as err:
            print("insert table 'mytable' from file 'mysql-test.dat' -- failed.")
            print("error: {}".format(err.msg))
            sys.exit()
 
try:
    cursor.execute(select_sql)
    for (id, name, age) in cursor:
        print("id:{}  name:{}  age:{}".format(id, name, age))
except mysql.connector.error as err:
    print("query table 'mytable' failed.")
    print("error: {}".format(err.msg))
    sys.exit()
 
cnx.commit()
cursor.close()
cnx.close()