1 c = conn.cursor()
2
3 # Create table
4 c.execute('''CREATE TABLE stocks
5 (date text, trans text, symbol text, qty real, price real)''')
6
7 # Insert a row of data
8 c.execute("INSERT INTO stocks VALUES ('2006-01-05','BUY','RHAT',100,35.14)")
9
10 # Save (commit) the changes
11 conn.commit()
12
13 # We can also close the connection if we are done with it.
14 # Just be sure any changes have been committed or they will be lost.
15 conn.close()
保存后的数据是持久的,并且可以在以后的访问中可用。 四、增删改查 1.建(create)表
1 c.execute("create table catalog (id integer primary key,pid integer,name varchar(10) UNIQUE,nickname text NULL)")
上面语句创建了一个叫catalog的表,它有一个主键id,一个pid,和一个name,name是不可以重复的,以及一个nickname默认为NULL。 2.删除表(DROP),清空表(TRUNCATE)
1 c.execute("delete from catalog") 3.插入(insert)数据,更改(uptate)数据
通常SQL语句中会用到python变量作为值(value)。不建议直接使用python的字符串运算来构造查询语句,因为这样是不安全的,会使你的程序容易受到SQL注入攻击。
可以使用DB-API提供的参数代换。在想使用值(value)的地方放置一个'?'作为占位符,然后提供一个由值(value)组成的元组作为游标(cursor)中execute()方法的第二个参数。(其他的数据库模块可能使用别的占位符,比如 '%s' 或者 ':1')
1 # Larger example that inserts many records at a time
2 purchases = [('2006-03-28', 'BUY', 'IBM', 1000, 45.00),
3 ('2006-04-05', 'BUY', 'MSFT', 1000, 72.00),
4 ('2006-04-06', 'SELL', 'IBM', 500, 53.00),
5 ]
6 c.executemany('INSERT INTO stocks VALUES (?,?,?,?,?)', purchases)
7
8 c.execute("UPDATE catalog SET trans='SELL' WHERE symbol = 'IBM'") 4.查询(select)数据
正如前面所说,提倡使用元组进行操作。
1 # Never do this -- insecure!
2 symbol = 'RHAT'
3 c.execute("SELECT * FROM stocks WHERE symbol = '%s'" % symbol)
4
5 # Do this instead
6 t = ('RHAT',)
7 c.execute('SELECT * FROM stocks WHERE symbol=?', t)
8 print c.fetchone() 5.删除(delete)数据
1 t=('RHAT')
2 c.execute("DELETE * FROM stocks WHERE symbol=?", t)