# !/usr/local/python
# -*- coding: utf-8 -*-
import cx_Oracle
import pymysql

# --------oracle連結資料庫----------------------------
student1 = {'id': 1011,
            'name': 7,
            'age': 18}
conn = cx_Oracle.connect('czth_sales/[email protected]:1521/ORCL')
sql1 = 'select * from student where id=%s' % (student1['id'])
cur = conn.cursor()
cur.execute(sql1)
result = cur.fetchall()
print('oracle查詢：', result)

sql = 'insert into student values(%s,%s,%s)' % (student1['id'], student1['name'], student1['age'])
cur.execute(sql)
conn.commit()

# --------mysql連結資料庫----------------------------
# conn = pymysql.connect(host ="134.175.103.124",port =3306,user= "wapn", password="123456", db="czth", charset='utf8')
config = {
    'host': '134.175.103.124',
    'port': 3306,
    'user': 'wapn',
    'password': '123456',
    'db': 'czth',
    'charset': 'utf8',
    'cursorclass': pymysql.cursors.DictCursor
}
conn = pymysql.connect(**config)
cursor = conn.cursor()

sql = 'SELECT * FROM  th_user_info'
count = cursor.execute(sql)
result = cursor.fetchall()
print('mysql查詢:', result)

# 如果沒有設定自動提交事務，則這裡需要手動提交一次
conn.commit()
# 發生錯誤時回滾
conn.rollback()
# 關閉遊標連線
cursor.close()
# 關閉資料庫連線
conn.close()