python实现mysql增删改
时间: 2023-10-21 22:27:23 浏览: 102
要实现Python对MySQL数据库的增删改操作,可以使用pymysql库。下面是具体的实现方法:
增加操作:
使用pymysql库连接到MySQL数据库,并执行插入操作。可以使用占位符的方式来防止SQL注入的问题。具体代码如下所示:
```
import pymysql
def get_conn():
conn = pymysql.connect(host='localhost', port=3306, user='root', passwd='root', db='test1')
return conn
def insert(sql, args):
conn = get_conn()
cur = conn.cursor()
result = cur.execute(sql, args)
print(result)
conn.commit()
cur.close()
conn.close()
if __name__ == '__main__':
sql = 'INSERT INTO test_student_table VALUES(%s, %s, %s);'
args = (2, 'wang', 13)
insert(sql, args)
```
删除操作:
同样使用pymysql库连接到MySQL数据库,并执行删除操作。可以使用占位符的方式传递参数,以避免SQL注入的问题。具体代码如下所示:
```
import pymysql
def get_conn():
conn = pymysql.connect(host='localhost', port=3306, user='root', passwd='root', db='test1')
return conn
def delete(sql, args):
conn = get_conn()
cur = conn.cursor()
result = cur.execute(sql, args)
print(result)
conn.commit()
cur.close()
conn.close()
if __name__ == '__main__':
sql = 'DELETE FROM test_student_table WHERE id = %s;'
args = (1,)
delete(sql, args)
```
更新操作:
同样使用pymysql库连接到MySQL数据库,并执行更新操作。可以使用占位符的方式传递参数,以避免SQL注入的问题。具体代码如下所示:
```
import pymysql
def get_conn():
conn = pymysql.connect(host='localhost', port=3306, user='root', passwd='root', db='test1')
return conn
def update(sql, args):
conn = get_conn()
cur = conn.cursor()
result = cur.execute(sql, args)
print(result)
conn.commit()
cur.close()
conn.close()
if __name__ == '__main__':
sql = 'UPDATE test_student_table SET NAME=%s WHERE id = %s;'
args = ('zhangsan', 1)
update(sql, args)
```
以上是使用Python实现MySQL的增删改操作的方法。通过pymysql库连接到数据库,然后执行相应的SQL语句即可实现对数据库的操作。同时,使用占位符的方式传递参数可以防止SQL注入的问题。<span class="em">1</span><span class="em">2</span><span class="em">3</span><span class="em">4</span>
阅读全文