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()