如何在pymysql中开始事务？(mysql)
在pymysql中开始事务，可以通过以下步骤实现：
- 导入pymysql模块：import pymysql
- 建立与MySQL数据库的连接：conn = pymysql.connect(host='localhost', user='username', password='password', database='database_name')其中，
host是MySQL服务器地址，user是数据库用户名，password是数据库密码，database是要连接的数据库名称。 - 创建游标对象：cursor = conn.cursor()
- 开始事务：conn.begin()
- 执行事务操作：try: # 执行SQL语句 sql = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)" values = ('value1', 'value2') cursor.execute(sql, values) # 提交事务 conn.commit() print("事务执行成功！") except Exception as e: # 发生异常时回滚事务 conn.rollback() print("事务执行失败：", str(e))在事务中可以执行多个SQL语句，如果其中任何一个操作失败，可以通过回滚事务来撤销之前的操作。
- 关闭游标和数据库连接：cursor.close() conn.close()
这样就完成了在pymysql中开始事务的过程。在事务中，可以执行各种数据库操作，如插入、更新、删除等。pymysql是一个Python与MySQL数据库交互的库，通过使用pymysql，可以方便地在Python程序中操作MySQL数据库。
腾讯云提供了云数据库MySQL服务，可以满足各种规模的数据库需求。您可以通过腾讯云云数据库MySQL产品了解更多信息：腾讯云云数据库MySQL。
相关·内容
1回答
我的脚本从文件中读取MYSQL更新查询，然后使用autocommit = 0立即执行这些查询。但是，如果我删除了conn.commit()，它仍然一个一个地运行，尽管我还没有完成。错误在哪里？
import pymysql
conn = pymysql.connect(host='x', unix_socket='/tmp/mysql.sock',user='x', passwd='x', db='x')
fileHandle = open ( 'mysqlout.txt' )
fileList =
浏览 11提问于2012-02-11得票数 4
3回答
插入似乎没有发生
、、
我正在使用gevent和gevent-mysql (我也使用了pymysql来达到同样的效果)。它可以很好地选择，但是无论我做什么，我都不能让它运行一次插入。我没主意了。
conn = geventmysql.connect(host='localhost', port=3306, user='root', db='content')
cur = conn.cursor()
cur.execute("insert into placement (placement_name, some_id) values ('static
浏览 2提问于2011-05-21得票数 1
回答已采纳
3回答
我在使用pymysql和python运算符时遇到了一些麻烦。不过，我对python运算符了解不多。
我想在数据库中插入一些值。代码：
import pymysql
conn = pymysql.connect(host='127.0.0.1', unix_socket='/Applications/MAMP/tmp/mysql/mysql.sock', user='root', passwd='root', db='db2', charset='utf8')
cur = conn.cursor()
浏览 2提问于2013-06-17得票数 1
回答已采纳
我使用pymysql连接mysql，并在连接时设置一个read_timeout：
conn = pymysql.connect(host=host,port=port,user=user,passwd=passwd,read_timeout=60)
我的查询代码在这里：
try:
cur.execute(sql)
rows = cur.fetchall()
except:
# timeout
logging.error()
finally:
cur.close()
conn.close()
当我执行长时间查询时，代码会引发超时错误，最后curso
浏览 0提问于2019-05-06得票数 1
回答已采纳
在flask中，我计划使用MySQL，因此：from flaskext.mysql import MySQL 然而，当我运行flask应用程序时，我遇到了以下错误： pymysql.err.OperationalError: (2003, "Can't connect to MySQL server on 'xx.xx.x.xx:xxxx' ([Errno -2] Name or service not known)") 问题是，我从一开始就不打算使用pymysql。虽然我已经安装了这个包，但我并没有导入它，那么为什么这个错误与pymysql有关呢？
浏览 77提问于2019-04-30得票数 0
1.sqlite3
import sqlite3
con=sqlite3.connect("g:\\mytest1.db")
cur=con.cursor()
cur.execute('create table test (上市 TEXT)')
con.commit()
cur.close()
con.close()
我成功地创建了一个测试表mytest1.db，并将汉字名为"上市“作为字段。
2.在mysql命令控制台中。
C:\Users\root>mysql -uroot -p
Welcome to the MySQL monito
浏览 2提问于2014-04-20得票数 2
回答已采纳
我使用的是pymysql.cursors和一个简化的代码示例，它从表中加载一行并每秒钟打印一次：
#!/usr/bin/env python3
import pymysql.cursors
import time
conn = pymysql.connect(host='localhost',
# credentials etc.
cursorclass=pymysql.cursors.DictCursor)
while True:
with conn.cursor() as cursor:
cursor.execute("
浏览 5提问于2015-11-06得票数 17
回答已采纳
2回答
PyMysql更新查询
、、、
我一直在尝试使用PyMysql，到目前为止，我所做的一切都是有效的(选择/插入)，但当我试图更新它时，它就是不起作用，没有错误，什么都没有，什么也做不了。
import pymysql
connection = pymysql.connect(...)
cursor = connection.cursor()
cursor.execute("UPDATE Users SET IsConnected='1' WHERE Username='test'")
cursor.close()
connection.close()
是的，我已经仔细检查了Us
浏览 4提问于2013-07-20得票数 15
回答已采纳
访问MySQL数据库的python包PyMySQL似乎不支持SELECT ...用于更新。
在下面的代码中，我使用SELECT...FOR UPDATE读取函数f()中的some_table，使用UPDATE修改g()中的表，并为每个函数派生50个线程。
我预计会发生死锁，因为SELECT...FOR更新应该会阻止g产生的线程，但实际上并没有发生死锁。有人能解释一下原因吗？
from threading import Thread
import pymysql
def f():
db = pymysql.connect("localhost", "tester
浏览 0提问于2015-07-29得票数 5
4回答
我使用pymysql客户端连接到我的烧瓶API中的mysql，在它突然开始抛出这个错误之后，每件事情都正常工作了几天(大约1-2天)。
Traceback (most recent call last):
File "/usr/local/lib/python3.4/dist-packages/pymysql/connections.py", line 1039, in _write_bytes
self._sock.sendall(data)
TimeoutError: [Errno 110] Connection timed out
During handli
浏览 7提问于2017-12-08得票数 8
回答已采纳
我想使用community.mysql.mysql_user模块。它需要PyMySQL或MySQLdb。我在本地主机上安装了带有PyYySQL的pip3 install pymysql，但是仍然出现了一个关于缺少PyMySQL的错误消息。我想也许我应该用sudo安装到一个系统目录中，但是错误仍然出现。
在再次使用pip3卸载之后，以下内容也没有帮助：
sudo apt install --yes python3-pymysql
sudo apt install --yes python3-mysqldb
来自PYPI上的PyMySQL页面的installation命令(python3 -m P
浏览 0提问于2021-12-11得票数 0
回答已采纳
我有一个托管在GCP上的MySQL数据库实例，我正在使用 python包连接到它。我想从一个名为Basic的数据库表中删除一些行。
我编写的代码如下所示。变量conf包含到数据库实例的连接详细信息。
import pymysql
import pandas as pd
# Establish connection.
connection = pymysql.connect(**conf)
cursor = connection.cursor()
# Delete rows of table.
try:
cursor.execute("DELETE FROM Basic WH
浏览 5提问于2022-12-01得票数 0
这是AWS函数的lambda_function.py代码，在该代码中，我将读取S3桶中的CSV数据，并将其插入到S3 MySQL数据库中。
import json
import boto3
import sys
import logging
import rds_config
import pymysql
import csv
s3_client = boto3.client("s3")
#rds settings
rds_host = "myrdsdatabase-xxxxx-amazonaws.com"
name = rds_config.db_use
浏览 0提问于2020-07-22得票数 1
回答已采纳
4回答
我已经使用sudo python install PyMySql下载了pymysql，它显示pip3模块安装成功。 ? 但是当我尝试导入它时，它显示没有使用此名称的模块。 ? 实际上，我在Ansible中为mysql root用户密码更新写了一个剧本，Ansible需要这个pymysql模块。
浏览 109提问于2020-01-17得票数 1
回答已采纳
我有production_table和stage_table。我有一个python脚本，运行了几个小时，并在stage_table中生成数据。我希望在脚本的末尾将COPY数据从stage_table到production_table。
基本上这就是我想要的：
1. TRUNCATE production_table
2. COPY production_table from stage_table
这是我的密码：
from sqlalchemy import create_engine
from sqlalchemy.sql import text as sa_text
engine = cr
浏览 1提问于2018-08-02得票数 0
回答已采纳
我知道这个问题已经问过好几次了，但我还没有发现一个与我所处理的问题有关的问题。我有一个MySQL数据库托管在上。我正在运行Google中的python脚本，以连接到数据库来运行查询。过去一切正常运行，但现在我在与服务器的初始连接上出现了以下错误。
File "/usr/local/lib/python3.5/dist-packages/pymysql/__init__.py", line 94, in Connect
return Connection(*args, **kwargs)
File "/usr/local/lib/python3.5/dist-pa
浏览 1提问于2021-06-23得票数 0
我对python代码非常陌生，我做了一些小测试来验证功能。
目前正在尝试在RDS MySQL和python函数之间建立连接。
但是，它似乎在代码本身中失败了，我不知道为什么会发生这种情况。外面有几个导游，但他们似乎都过时了，不能为我工作。
以下是我为使其正常工作所采取的步骤(使用MAC-12.3.1和VS-Studio 1.62.3)：
创建MYSQL RDS
连接到MYSQL，并创建一个名为"igor“的数据库，其表名为"lumigor"，列有2列: id和name (填充随机数据)。
在本地机器上创建一个包含代码和包的文件夹。
安装版本Python3
浏览 11提问于2022-04-19得票数 0
我在将我的python3 -烧瓶应用程序(运行在Google上)与mySQL数据库实例连接时遇到了麻烦。具体来说，当我通过Google的shell命令行中的'python main.py‘运行开发服务器时，我无法连接。
我使用pymysql包并通过create_engine函数进行连接。
我成功地连接到已部署的应用程序：create_engine('mysql+pymysql://root:<pass>@/<instance>?unix_socket=/cloudsql/<project>:<region>:<databas
浏览 2提问于2021-04-15得票数 0
回答已采纳
这是我第一次使用MySQL而不是SQLite3来部署站点，所以在阅读了一些文档之后，我发现必须更改这样的文件：
settings.py
DATABASES = {
'default': {
'ENGINE': 'django.db.backends.mysql',
'NAME': 'my_site_db',
'USER': 'username',
'PASSWORD': 'password
浏览 1提问于2017-02-22得票数 2
回答已采纳
让我创建一个用于讨论的用例。
CREATE DATABASE sample;
USE sample;
CREATE TABLE quote (
`id` int(2) unsigned NOT NULL AUTO_INCREMENT,
`code` text ,
`date` date DEFAULT NULL,
`close` double DEFAULT NULL,
PRIMARY KEY (`id`)
) ;
INSERT INTO quote (`code`, `date`, `close`)
VALUES ('epm', '202008
浏览 2提问于2020-08-26得票数 2
回答已采纳
我的ansible代码如下所示：
---
- name: Install python
apt:
pkg: "{{ item }}"
update-cache: yes
state: latest
with_items:
- python
- python-dev
- name: Install pymysql
pip:
name: "{{ item }}"
executable: pip
state: present
with_items:
- PyMySQL==0.7.
浏览 2提问于2022-04-07得票数 1
2回答
我试图使用pymysql连接，使用与文档中提供的示例非常接近的代码：
数据库具有公共ip，没有授权的网络(因为cf应该使用套接字)，我的用户创建时允许从任何地方访问。
使用Cloud代理在本地运行很好，但是在Google上，我被拒绝了连接。
编辑:用env 本地运行的代码更新的示例
import logging
import os
import pymysql
from pymysql.err import OperationalError
mysql_conn = None
def __get_cursor():
try:
return mysql_conn
浏览 0提问于2019-09-23得票数 2
回答已采纳
我想用scrapy编写一个爬虫，在我写完爬虫文件，项目文件，管道文件等后，我想将数据保存到数据库中，但我发现项目‘’url‘的数据类型实际上是字符串类型，字符串包含列表，我无法获得里面的数据，我找不到问题所在。
import pymysql
from . import settings
class JumiaspiderPipeline(object):
def __init__(self):
self.conn=pymysql.connect(
host=settings.MYSQL_HOST,
db=settings.MYSQL_DBNAME,
浏览 22提问于2018-09-05得票数 0
回答已采纳
mysql语句中定义了一个变量，该变量在sql语句中进行操作，但是当我使用sqlalchemy执行sql语句时，错误将显示在定义变量的位置。语法错误(设置为@num=1;)，似乎sqlalchemy无法使用定义的变量执行sql
mysql代码：
set @a=0;set @b=null;select @a:=if(@b=num,@a+1,1) as rk,@b:=num from logs;
python代码：
engine=create_engine("mysql+pymysql://root:root@localhost:3306/test",echo=True)
c =
浏览 15提问于2022-07-17得票数 0
1回答
我是工作从GCP的灯安装在debian 9机器上。
我在试图将pymysql导入到项目时出现了一些依赖错误。我不完全理解这个错误，也不完全理解我错过了什么。这是我正在犯的错误：
>>> import pymysql
Traceback (most recent call last):
File "<stdin>", line 1, in <module>
File "/home/philip_plachta/.local/lib/python3.5/site-packages/pymysql/__init__.
浏览 1提问于2021-03-01得票数 2
回答已采纳
1回答
我正在使用flask-sqlalchemy连接到mysql
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:''@127.0.0.1/pharmbase'
虽然这在本地运行良好，但heroku在部署时无法连接到MySQL服务器。以下是trackback消息
2021-01-19T15:36:19.137152+00:00 app[web.1]: sqlalchemy.exc.OperationalError: (pymysql.err.OperationalError)
浏览 0提问于2021-01-19得票数 0
1回答
@改为%40
、、、、
我使用sqlalchemy并使用
url = url.URL(
drivername,
host,
username,
password,
database)
这不管用
url = url.URL(
drivername='mysql+pymysql',
host='abc.com',
us
浏览 6提问于2022-12-04得票数 -1
我对mysql非常陌生。我用，实例制作了服务器。我知道如何连接本地主机mysql，所以我尝试了同样的方法。
import pymysql
connetion = pymysql.connect(host='xxx.xxx.xxx.xxx',
port = 80
user='userid',
password='userpw',
db='bit
浏览 0提问于2019-12-21得票数 1
我想将我的python脚本连接到docker中的MySQL。这是我的docker-compose文件： version: '3.7'
services:
mysql:
image: mariadb:${MARIADB_VERSION:-latest}
container_name: mysql
volumes:
- ./mysql:/var/lib/mysql
environment:
- MYSQL_ROOT_PASSWORD=${MYSQL_ROOT_PASSWORD:-password}
- M
浏览 43提问于2021-01-06得票数 1
回答已采纳
我有证据：
import pymysql
conn = pymysql.connect(host='127.0.0.1', unix_socket='/opt/lampp/var/mysql/mysql.sock', user='root', passwd=None, db='test')
cur = conn.cursor()
cur.execute("test < /mypath/test.sql")
cur.close()
conn.close()
我总是收到错误：
1064 , "You ha
浏览 1提问于2014-10-27得票数 0
1回答
我有一个在MySQL表中插入一些记录的dag，我想每隔2小时运行我的dag。为此，我有以下代码：
from datetime import timedelta, datetime
import pymysql
import airflow
from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.operators import MySqlOperator
default_args = {
'owner': 'airflow
浏览 54提问于2021-06-04得票数 0
回答已采纳
使用Python-2.7.6和包"pymysql“和" MySQL - python”是使用python脚本中的“easeinstall-2.7”安装的，我正在尝试连接到远程mysql服务器(客户端和mysql服务器都位于同一个子网)。
剧本：
cluster_inbound_ip="10.0.xx.xx"
conn = pymysql.connect(host=cluster_inbound_ip, port=cluster_port, user=db_root_user, passwd=db_root_pass, db = db_name)
编译脚本后出错
浏览 9提问于2014-03-04得票数 0
回答已采纳
我使用与MySQL连接。我想在MySQL命令中执行“喜欢”查询。
以下是命令：
"select * from table where c1 > '2015-11-01' and c2 not like '%word%'"
我有一个表table，其中有c1、c2和c3列。
import pymysql.cursors
def query_my(my_query):
connection = pymysql.connect(host='',
user='&
浏览 1提问于2015-11-02得票数 0
回答已采纳
我在Mac上使用pymysql从容器外部连接到MySQL容器时遇到了问题，尽管我可以使用MySQL工作台连接到docker MySQL。
我使用了以下docker-compose.yaml：
version: '3'
services:
db:
image: mysql:latest
volumes:
- ./data/db:/var/lib/mysql
ports:
- 6603:3306
restart: always
environment:
MYSQL_ROOT_PASSWORD: pass
浏览 49提问于2018-06-16得票数 1
4回答
我正试图用python管道连接到CloudSQL。
实际情况
我可以在没有任何问题的情况下使用DirectRunner
我不能用DataflowRunner连接
连接函数
def cloudSQL(input):
import pymysql
connection = pymysql.connect(host='<server ip>',
user='...',
passwor
浏览 0提问于2018-12-18得票数 5
我正在尝试在Apache Airflow中使用MySQL。我已经使用PymySQL来查询MySQL数据库，并且还没有安装MySQLDb。因此，我得到了错误：
from airflow.hooks.mysql_hook import MySqlHook
File "/anaconda3/anaconda/lib/python3.6/site-packages/airflow/hooks/mysql_hook.py", line 15, in <module>
import MySQLdb
ModuleNotFoundError: No module na
浏览 1提问于2018-09-15得票数 2
我试图使用bytes在BLOB类型列中插入pymysql。
要求是插入时不应对字节进行编码。
执行时，我的SQL如下所示：
insert into product values(b'<\xf0Q,\x18\x99y\x86\xda\x81\xc8\x869Q\xf8\xc9\xb2\xc6NqG\xcfV\xbf{\x86\xf8\nJ\x0b\xfa)');
在尝试插入时获取以下错误。
cursor.execute(sql)
File "home/.pyenv/versions/3.7.7/lib/python3.7/site-packages/py
浏览 0提问于2021-12-01得票数 0
回答已采纳
1回答
在MySql中对数据库进行更改(更新、删除、插入、创建等)后，是否可以让MySql转储数据库或将上次运行的查询导出到sql文件中？
浏览 2提问于2012-02-27得票数 0
回答已采纳
我希望在字符串中的每个引号之前插入一个\，以便使用pymysql将其插入到我的SQL数据库中。如果我不能转义引号，我就不能在数据库中插入字符串。
例如：
“好的，我准备好了”
必须：
str = "ok I“准备好了
但是打印必须是：“好的，我准备好了”
为了做到这一点，我已经做到了：
str = str.replace("'", "\'")
但是它不起作用，我仍然不能在我的数据库中插入我的字符串。我有一条错误消息：
(1064，u“您的SQL语法有错误；检查与您的MySQL服务器版本相对应的手册，以获得正确的语法，以便
浏览 5提问于2017-06-29得票数 1
回答已采纳
我正在开发一个数据收集应用程序，它涉及到对MySQL数据库的常量插入。我正在使用Python和PyMySQL来完成这项工作。我需要每秒在主表中插入大约100行。python进程一直在运行，并维护与驻留在远程服务器上的MySQL数据库的持续连接。
我知道，一般来说，最好是以缓冲区的形式插入数据(一次插入多行)，而不是单独插入。每100次左右的插入进行一次提交(PyMySQL中的connection.commit())是否可以实现与一次性插入大量数据相同的开销减少？
出于语法上的原因，将行插入分离到单独的操作中会更容易。
浏览 2提问于2018-07-01得票数 0
我将以下内容放在我的manage.py中(使用django-celery 3.0.21)：
import eventlet
pymysql = eventlet.import_patched('pymysql')
pymysql.install_as_MySQLdb()
当我尝试启动django或芹菜时，会出现以下错误：
Traceback (most recent call last):
File "manage.py", line 8, in <module>
pymysql.install_as_MySQLdb()
File &
浏览 10提问于2014-03-28得票数 1
回答已采纳
遵循在线教程，我正在尝试在MySQL中使用Python。在他在Ubuntu上安装mysql的教程中，我使用的是Windows和Anaconda。我只想用基本命令"mysql -u root -p“启动mysql，我假设在conda上也是一样的。
我已经通过简单的安装程序(MySQL Workbench works)下载并安装了MySQL。我已经使用pip安装了"mysqlclient“。我已经使用conda安装了"pymysql“和"mysql-connector-python”。
我仍然不能通过conda启动mysql。我有一些使用MySQL的经验，是Pyth
浏览 2提问于2017-09-04得票数 2
我有一个相当大的数据集，大约有6,000,000行x 60列，我正试图将其插入到数据库中。我正在将它们分块，并使用我编写的一个类和pymysql将它们一次插入到mysql数据库中。问题是，我在编写代码时偶尔会让服务器超时，所以我修改了我的executemany调用，以便在出现错误时重新连接。当我失去连接一次时，这可以很好地工作，但是如果我第二次丢失错误，我会得到一个pymysql.InternalException，说明超过了锁等待超时。我想知道如何修改下面的代码来捕获它，并在再次尝试之前完全销毁事务。 我尝试在连接上调用rollback()，但是如果由于不再有游标而破坏连接，则会导致另一个
浏览 38提问于2019-04-06得票数 0
我正在使用以下配置连接到OTP的：
otp:
url: 'mysql+pymysql://$USER:$PASS@$MYSQL_SERVER/$DB'
table: $TABLE
当Gramex启动时，它报告了一个异常：
InternalError: (pymysql.err.InternalError) (3159, 'Connections using insecure transport are prohibited while --require_secure_transport=ON.')
建议传递一个虚拟的ssl:数据集。
如何将此传
浏览 9提问于2022-06-02得票数 0
我在制作包含python/bottle web应用程序的容器以访问mysql服务器/容器时遇到了问题。
docker-compose build
Step 8/9 : RUN python3 bin/initdb.py
---> Running in 30d963677711
Traceback (most recent call last):
File "/usr/local/lib/python3.7/dist-packages/pymysql/connections.py", line 583, in connect
**kwargs)
File
浏览 62提问于2020-02-20得票数 1
使用相同的数据库凭据，MySQLdb可以成功进行身份验证，而pymysql则不能。这种情况只发生在一个特定用户身上。
>>> import pymysql
>>> import MySQLdb
>>> MySQLdb.connect(**creds)
<_mysql.connection open to 'xxx' at edeae8>
>>> pymysql.connect(**creds)
...
pymysql.err.OperationalError: (1045, "Acces
浏览 21提问于2018-08-15得票数 0
2回答
sqlalchemy.exc.OperationalError：(pymysql.err.OperationalError) (2003年，“无法连接到'localhost‘上的MySQL服务器(Errno 2没有这样的文件或目录)”)(此错误的背景为：)
我被这个错误困住很久了，我正试图将我的应用程序引擎python代码连接到mysql实例的云sql。这是我第一次使用google，cloud.below是我用app.yaml编写的代码。
runtime:
python37
vpc_access_connector:
name: "projects/projec
浏览 7提问于2020-02-02得票数 0
此错误发生在pymysql和mysql-connector-python上。而不是MySQL外壳。MySQL外壳可以正常通过mysql -u root -p登录。 错误如下所示： In [1]: import mysql.connector
In [2]: mydb = mysql.connector.connect(
...: host="localhost",
...: user="root",
...: passwd="password"
...: )
ProgrammingError: 1045
浏览 38提问于2019-10-14得票数 0
回答已采纳
2回答
我正在尝试使用AWS连接到AWS。我将PyMySQL安装到目录中，并使用下面的代码和库构建了包
import sys
import pymysql
def lambda_handler(event, context):
string=""
try:
connection = pymysql.connect(host='',
user='',
浏览 1提问于2018-01-31得票数 2
1回答
我使用Python3.5.2和PyMySQL
在创建了MySQL数据库之后
import pymysql
conn = pymysql(host='127.0.0.1',unix_socket='/tmp/mysql.sock',user='root',passwd=None,db='mysql')
AttributeError:模块‘套接字’没有属性'AF_UNIX‘
附注：在我的MySQL中设置win10时，端口3306无法工作(使我无法继续)
所以我把端口改为306，然后工作
这对我的错误有什么影响吗？
它
浏览 2提问于2016-12-04得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
