python连接mysql,进行数据库表变更和查询:
python mysql insert delete query:
#!/usr/bin/python import mysqldb def doinsert(cursor,db): #insert # prepare sql query to insert a record into the database. sql = "update employee set age = age+1 where sex = '%c'" %('m') try: cursor.execute(sql) db.commit() except: db.rollback() def do_query(cursor,db): sql = "select * from employee \ where income > '%d'" % (1000) try: # execute the sql command cursor.execute(sql) # fetch all the rows in a list of lists. results = cursor.fetchall() print 'resuts',cursor.rowcount for row in results: fname = row[0] lname = row[1] age = row[2] sex = row[3] income = row[4] # now print fetched result print "fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \ (fname, lname, age, sex, income ) except: print "error: unable to fecth data" def do_delete(cursor,db): sql = 'delete from employee where age > {}'.format(20) try: cursor.execute(sql) db.commit() except: db.rollback() def do_insert(cursor,db,firstname,lastname,age,sex,income): sql = "insert into employee(first_name, \ last_name, age, sex, income) \ values ('%s', '%s', '%d', '%c', '%d' )" % \ (firstname,lastname,age,sex,income) try: cursor.execute(sql) db.commit() except: db.rollback() # open database connection # change this to your mysql account #connect(server,username,password,db_name) db = mysqldb.connect("localhost","root","root","pydb" ) # prepare a cursor object using cursor() method cursor = db.cursor() do_query(cursor,db) doinsert(cursor,db) do_query(cursor,db) do_delete(cursor,db) do_query(cursor,db) do_insert(cursor,db,'hunter','xue',22,'m',2000) do_insert(cursor,db,'mary','yang',22,'f',5555) do_insert(cursor,db,'zhang','xue',32,'m',5000) do_insert(cursor,db,'hunter','xue',22,'m',333) do_query(cursor,db) # disconnect from server db.close()
之后可以在此基础上根据需要进行封装。
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
如对本文有疑问, 点击进行留言回复!!
在Ubuntu/Linux环境下使用MySQL开放/修改3306端口和开放访问权限
ORM框架Peewee(高级连接)peewee连接池、主从、重连、ssh连接
记一次Mysql主从复制延迟,Waiting for dependent transaction to commit
网友评论