#!/usr/bin/python
#coding=utf-8
import MySQLdb
import sys
DB_USERNAME='scto'
DB_PASS='xjtb2016'
#DB_CONF_PATH=
DB_HOST='127.0.0.1'
DB_PORT='3306'
DB_BASENAME='test'
DB_CHAR_SET='utf8'
#連接數據庫
def get_connect():
return MySQLdb.connect(host=DB_HOST,user=DB_USERNAME,passwd=DB_PASS,db=DB_BASENAME,charset=DB_CHAR_SET)
#獲取cursor
def get_cursor(conn):
return conn.cursor()
#打印
def show_print(conn,sql):
cursor = get_cursor(conn)
re = cursor.execute(sql)
for row in cursor.fetchall():
# print "%s" %row
print(row)
# close(cursor,conn)
#關閉數據庫連接
def conn_close(conn):
if conn != None:
conn.close()
#關閉cursor方法
def cursor_close(cursor):
if cursor !=None:
cursor.close()
#全部服務關閉
def close(cursor,conn):
cursor_close(cursor)
conn_close(conn)
#查看數據庫表情況
def get_databases(conn):
show_print(conn,"show databases")
#查看數據庫中的表
def get_tables(conn):
# sql="show tables"
show_print(conn,"show tables")
#查看數據庫啟動時間
def get_mysqluptime(conn):
show_print(conn,"show global status like 'uptime';")
#插入表數據
def insert_table(conn):
print "歡迎使用插入表數據"
print "<<<----------------------------"
# sql = "insert into hh(id,name,age) values(%s,%s,%s)"
sql = "insert into hh(id,info) values(2,'hej')"
params = ('2','hej','22')
print "---------------------------->>>>"
cursor = get_cursor(conn)
cursor.execute(sql)
# result = cursor.execute(sql,params)
conn.commit()
# close(cursor,conn)
# return result
#查看表中相關數據
def query_table(conn,table):
if table != ' ':
sql = 'select * from ' + table
print "您要查看的具體語句為:\t %s" %sql
show_print(conn,sql)
else:
print ("沒有您想查看的表\t"+table)
#更新表數據
def update_table():
sql= 'update student set name = %s where id = 1'
params = ("Hehaha")
conn = get_connect()
cursor = get_cursor(conn)
result = cursor.execute(sql, params)
conn.commit()
close(cursor, conn)
return result
#創建表
def create_table(tablename):
if tablename != '':
conn = get_connect()
cursor = get_cursor(conn)
cursor.execute('create table '+tablename+'(id int,info varchar(20))')
conn.commit()
else:
print ("您沒有輸入您想創建的數據庫表名\t"+tablename)
#cursor_close(cursor)
#查看連接信息
def print_conn_info():
print ("數據庫連接數據為:\t"+ DB_HOST+'\t' + DB_USERNAME +'\t' + DB_PASS +'\t'+ DB_BASENAME)
def delete_date(conn,tablename,datasize):
cursor = get_cursor(conn)
cursor.execute('delete from '+tablename+' where id='+datasize)
conn.commit()
def get_inputinfo():
print "請輸入:\t\n"
result=raw_input()
print ("您的輸入為:\t\n"+result)
return result
def main():
#獲取標准輸入
result=get_inputinfo()
#連接數據庫
conn=get_connect()
#查看數據庫表情況
get_databases(conn)
#查看數據庫中的表
get_tables(conn)
#查看數據庫啟動時間
get_mysqluptime(conn)
#插入表數據
insert_table(conn)
print "請輸入您要查詢的數據庫表名"
sql=raw_input()
#查看表中相關數據
query_table(conn,sql)
query_table(conn,"student")
#修改數據
update_table()
print "請輸入您要創建的數據庫表名"
tablename=raw_input()
#創建表
create_table(tablename)
#查看連接信息
print_conn_info()
#刪除指定表中的指定數據
print "請輸入您要刪除的數據庫表名\t"
tablename=raw_input()
print "請輸入您要刪除的數據"
datasize=raw_input()
delete_date(conn,tablename,datasize)
conn_close(conn)
if __name__=='__main__':
main()