import pyodbc 

DBfile = r"F:\python\caiji.mdb" # 數(shù)據(jù)庫(kù)文件需要帶路徑
print(DBfile)
conn = pyodbc.connect(r"DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};DBQ="+ DBfile +";Uid=;Pwd=;") 
cursor = conn.cursor() 
SQL = "SELECT * from sites;" 
for row in cursor.execute(SQL): 
 print(row) 
cursor.close() 
conn.close() 

# -*-coding:utf-8-*-
import pyodbc

# 連接數(shù)據(jù)庫(kù)（不需要配置數(shù)據(jù)源）,connect()函數(shù)創(chuàng)建并返回一個(gè) Connection 對(duì)象
cnxn = pyodbc.connect(r'DRIVER={Microsoft Access Driver (*.mdb, *.accdb)};DBQ=.\data\goods.mdb')
# cursor()使用該連接創(chuàng)建（并返回）一個(gè)游標(biāo)或類(lèi)游標(biāo)的對(duì)象
crsr = cnxn.cursor()

# 打印數(shù)據(jù)庫(kù)goods.mdb中的所有表的表名
print('`````````````` goods ``````````````')
for table_info in crsr.tables(tableType='TABLE'):
  print(table_info.table_name)


l = crsr.execute("SELECT * from goods WHERE goodsId='0001'")# [('0001', '扇葉', 20, 'A公司', 'B公司', 2000, 2009)]

rows = crsr.execute("SELECT currentStock from goods") # 返回的是一個(gè)元組
for item in rows:
  print(item)

l = crsr.execute("UPDATE users SET username='lind' WHERE password='123456'")
print(crsr.rowcount) # 想知道數(shù)據(jù)修改和刪除時(shí)，到底影響了多少條記錄，這個(gè)時(shí)候你可以使用cursor.rowcount的返回值。

# 修改數(shù)據(jù)庫(kù)中int類(lèi)型的值
value = 10
SQL = "UPDATE goods " \
   "SET lowestStock=" + str(value) + " " \
   "WHERE goodsId='0005'"

# 刪除表users
crsr.execute("DROP TABLE users")
# 創(chuàng)建新表 users
crsr.execute('CREATE TABLE users (login VARCHAR(8),userid INT, projid INT)')
# 給表中插入新數(shù)據(jù)
crsr.execute("INSERT INTO users VALUES('Linda',211,151)")

''''''
# 更新數(shù)據(jù)
crsr.execute("UPDATE users SET projid=1 WHERE userid=211")

# 刪除行數(shù)據(jù)
crsr.execute("DELETE FROM goods WHERE goodNum='0001'")

# 打印查詢的結(jié)果
for row in crsr.execute("SELECT * from users"):
  print(row)


# 提交數(shù)據(jù)（只有提交之后，所有的操作才會(huì)對(duì)實(shí)際的物理表格產(chǎn)生影響）
crsr.commit()
crsr.close()
cnxn.close()

cnxn =pyodbc.connect('DRIVER={SQL Server};SERVER=localhost;DATABASE=testdb;UID=me;PWD=pass')
cursor =cnxn.cursor()

cnxn =pyodbc.connect('DSN=test;PWD=password')
cursor =cnxn.cursor()

cursor.execute("select user_id, user_name from users")
row =cursor.fetchone()
if row:
 printrow

cursor.execute("select user_id, user_name from users")
row =cursor.fetchone()
print'name:', row[1]  # access by column index
print'name:', row.user_name # or access by name

while 1:
 row= cursor.fetchone()
 ifnot row:
 break
 print'id:', row.user_id

cursor.execute("select user_id, user_name from users")
rows =cursor.fetchall()
for row in rows:
 printrow.user_id, row.user_name

cursor.execute("select user_id, user_name from users"):
for row in cursor:
 printrow.user_id, row.user_name

for row in cursor.execute("select user_id, user_name from users"):
 printrow.user_id, row.user_name

cursor.execute("""
  select user_id, user_name
   from users
  where last_logon < '2001-01-01'
   and bill_overdue = 'y'
  """)

cursor.execute("""
  select user_id, user_name
   from users
  where last_logon < ?
   and bill_overdue = ?
  """,'2001-01-01','y')

cursor.execute("""
  select user_id, user_name
   from users
  where last_logon < ?
   and bill_overdue = ?
  """, ['2001-01-01','y'])

cursor.execute("select count(*) as user_count from users where age > ?",21)
row =cursor.fetchone()
print'%d users' %row.user_count

cursor.execute("insert into products(id, name) values ('pyodbc', 'awesome library')")
cnxn.commit()

cursor.execute("insert into products(id, name) values (?, ?)",'pyodbc', 'awesome library')
cnxn.commit()

cursor.execute("delete from products where id <> ?",'pyodbc')
printcursor.rowcount, 'products deleted'
cnxn.commit()

deleted =cursor.execute("delete from products where id <> 'pyodbc'").rowcount
cnxn.commit()

deleted =cursor.execute("delete from products where id <> 'pyodbc'").rowcount

deleted =cursor.execute("""
    delete
    from products
    where id <> 'pyodbc'
    """).rowcount

row =cursor.execute("select count(*) as user_count from users").fetchone()
print'%s users' %row.user_count

count =cursor.execute("select count(*) from users").fetchone()[0]
print'%s users' %count

maxid =cursor.execute("select coalesce(max(id), 0) from users").fetchone()[0]