import pymysql
import datainfo
import time
#獲取參數
host = datainfo.host
username = datainfo.username
password = datainfo.password
database = datainfo.db
print()
#測試數據庫連接
def testconnect():
#打開數據庫鏈接
db = pymysql.connect(host,username,password,database)
#使用cursor() 方法創建一個游標對象 cursor
cursor = db.cursor()
#使用execute()方法執行SQL查詢
cursor.execute("select version()")
#使用fetchone ()獲取單條數據
data = cursor.fetchone()
print(data)
db.close()
#插入數據庫
def InsertDate():
#打開數據庫鏈接
db = pymysql.connect(host,username,password,database,charset='utf8')
#使用cursor() 方法創建一個游標對象 cursor
cursor = db.cursor()
create_time = time.strftime('%Y-%m-%d %H:%M:%S')
update_time = time.strftime('%Y-%m-%d %H:%M:%S')
start_time = time.strftime('%Y-%m-%d %H:%M:%S')
end_time = time.strftime('%Y-%m-%d %H:%M:%S')
remark = "測試插入信息"
print("開始")
#Sql 插入語句
sql = "insert into demo(start_time,end_time,creat_time,update_time,remark) "
"VALUES ('%s','%s','%s','%s','%s')"
%(start_time,end_time,create_time,update_time,remark)
try:
#執行sql
print("執行插入")
tt = cursor.execute(sql)
print(tt)
db.commit()
except UnicodeEncodeError as e :
#發生錯誤時回滾
print(e)
db.rollback()
db.close()
#查詢操作
def selectData():
db = pymysql.connect(host, username, password, database, charset='utf8')
# 使用cursor() 方法創建一個游標對象 cursor
cursor = db.cursor()
sql = "select * from demo where id >='%d'" %(1)
try:
#執行sql
print("執行查詢")
cursor.execute(sql)
results = cursor.fetchall()
