sqlalchemy插入数据不起作用
在使用 SQLAlchemy 插入数据时，如果发现数据没有插入到数据库中，可能是由于以下几个常见原因导致的。以下是一些排查和解决问题的方法：
1. 确保会话提交
在 SQLAlchemy 中，所有的数据库操作都是通过会话（session）进行的。插入数据后，需要显式地提交会话才能将数据写入数据库。
from sqlalchemy import create_engine, Column, Integer, String
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
# 创建数据库引擎
engine = create_engine('sqlite:///example.db', echo=True)
# 创建基类
Base = declarative_base()
# 定义模型
class User(Base):
__tablename__ = 'users'
id = Column(Integer, primary_key=True)
name = Column(String)
age = Column(Integer)
# 创建表
Base.metadata.create_all(engine)
# 创建会话
Session = sessionmaker(bind=engine)
session = Session()
# 插入数据
new_user = User(name='Alice', age=30)
session.add(new_user)
# 提交会话
session.commit()
# 关闭会话
session.close()2. 检查是否有异常抛出
在插入数据时，可能会有异常抛出，导致数据没有插入成功。可以使用 try-except 块来捕获异常并进行处理。
try:
new_user = User(name='Bob', age=25)
session.add(new_user)
session.commit()
except Exception as e:
session.rollback() # 回滚会话
print(f"Error occurred: {e}")
finally:
session.close()3. 确保表结构正确
确保表结构已经正确创建。如果表结构不正确，插入数据时可能会失败。可以使用 Base.metadata.create_all(engine) 来创建表。
Base.metadata.create_all(engine)4. 检查数据库连接
确保数据库连接正确。如果数据库连接有问题，数据插入操作将无法成功。
engine = create_engine('sqlite:///example.db', echo=True)5. 确保数据类型匹配
确保插入的数据类型与表定义中的数据类型匹配。例如，如果表中的某一列定义为 Integer 类型，插入的数据也应该是整数类型。
new_user = User(name='Charlie', age=40) # age 应该是整数类型6. 使用 flush 方法
在某些情况下，可以使用 session.flush() 方法将数据写入数据库，但不提交事务。这在调试时可能会有帮助。
new_user = User(name='David', age=35)
session.add(new_user)
session.flush() # 将数据写入数据库，但不提交事务
session.commit() # 提交事务7. 检查自动提交设置
确保会话没有被设置为自动提交模式。如果会话被设置为自动提交模式，可能会导致数据没有正确插入。
Session = sessionmaker(bind=engine, autocommit=False)
session = Session()8. 确保没有其他事务干扰
确保没有其他事务干扰当前会话。如果有其他事务在进行，可能会导致数据插入失败。
9. 检查数据库日志
如果使用的是数据库服务器（如 MySQL、PostgreSQL 等），可以检查数据库日志，查看是否有任何错误信息。
10. 使用 bulk_save_objects 方法
在插入大量数据时，可以使用 bulk_save_objects 方法，这可能会提高性能并确保数据插入成功。
users = [User(name='Eve', age=28), User(name='Frank', age=33)]
session.bulk_save_objects(users)
session.commit()相关·内容
我试图为我的api创建一个异步数据库，但是当我插入一个datetime时，它存储了一个不同的值。我在Python文件中创建的数据库模式。 prices = sqlalchemy.Table(
"prices",
metadata,
sqlalchemy.Column("id", sqlalchemy.String),
sqlalchemy.Column("value", sqlalchemy.String),
sqlalchemy.Column("date", sqlalchemy.DateTime, primary_key=T
浏览 18提问于2020-06-19得票数 0
回答已采纳
2回答
我有一个sqlalchemy类映射到MySQL innoDB中的数据库表。该表有几列，我能够成功地填充除时间戳列以外的所有列：
映射：
class HarvestSources(Base):
__table__ = Table('harvested', metadata, autoload=True)
MySQL上的列是一个以CURRENT_TIMESTAMP作为默认值的时间戳，但是当我插入一行时，它被填充为NULL。
如果默认设置不起作用，那么我需要手动设置时间戳，我如何才能做到这两个。
将行插入到表中的SqlAlchemy代码：
source = HarvestSo
浏览 2提问于2013-07-24得票数 8
回答已采纳
6回答
当我使用sqlalchemy时，我遇到了一个缓存问题。
我使用sqlalchemy向MySQL数据库插入数据。然后，我让另一个应用程序处理这些数据，并直接更新它。
但是sqlalchemy总是返回旧数据，而不是更新后的数据。我认为sqlalchemy缓存了我的请求...所以..。我该如何禁用它？
浏览 3提问于2012-04-18得票数 23
回答已采纳
我有一个，其中包含几个列是列表。我想将它们作为ARRAY数据类型插入到我的雪花表中。
传统上，我使用PostgreSQL，并将其插入为df_to_insert.to_sql(TABLE_NAME, sqlalchemy_connection, **other_parameters)。
然而，我正在努力插入雪花。当我有一个列是一个列表时，sqlAlchemy雪花方言相信它是一个字符串：
表达式类型与列数据类型不匹配，需要数组，但获得了列NAME_OF_COLUMN_WITH_LISTS的VARCHAR(2)
通过添加显式的dtype，我尝试给sqlAlchemy引擎一个提示，说明该列不是
浏览 0提问于2019-04-14得票数 6
我在sqlalchemy中创建了一个sqlite数据库，并在其中插入了数据。现在，我想要获取插入的总行数。 我正在尝试遵循这个堆栈溢出问题的示例。 Get the number of rows in table using SQLAlchemy 然而，这涉及到创建一个“国会”类和geoalchemy库，我不确定它们来自哪里，或者它们是如何相关的。 这是我的代码 import sqlalchemy
from sqlalchemy import create_engine
engine = sqlalchemy.create_engine("sqlite:///dbfile/CSSumm
浏览 42提问于2019-06-08得票数 0
1回答
我希望在mytable (在DB2数据库中)中插入一条记录，并在该插入中获得生成的id。我正试图用python 2.7来做这件事。以下是我所做的：
import sqlalchemy
from sqlalchemy import *
import ibm_db_sa
db2 = sqlalchemy.create_engine('ibm_db_sa://user:pswd@localhost:50001/mydatabase')
sql = "select REPORT_ID from FINAL TABLE(insert into MY_TABLE values(D
浏览 0提问于2015-03-11得票数 2
回答已采纳
使用MSSQL (2012版)，我使用SQLAlchemy和pandas (在Python2.7上)将行插入Server表中。
在使用特定的服务器字符串尝试pymssql和pyodbc之后，我正在尝试一个odbc名称：
import sqlalchemy, pyodbc, pandas as pd
engine = sqlalchemy.create_engine("mssql+pyodbc://mssqlodbc")
sqlstring = "EXEC getfoo"
dbdataframe = pd.read_sql(sqlstring, engine)
浏览 0提问于2015-07-28得票数 3
回答已采纳
我有一个大约100 K行的postgres表。我提取了这个数据集并进行了一些转换，得到了一个包含100 K行的新熊猫数据。现在，我希望将此数据作为数据库中的一个新表加载。我使用to_sql来使用SQLAlchemy连接将数据转换为postgres表。然而，这是非常缓慢的，需要几个小时。如何使用SQLAlchemy加速数据库表中的数据插入？我想把插入速度从几个小时提高到几秒钟？有人能帮我吗？
我搜索了其他类似的关于Stackoverflow的问题。它们中的大多数将数据转换为csv文件，然后使用copy_from进行sql。我期待一个解决方案使用SQLAlchemy批量插入语句与熊猫数据。
下面是
浏览 0提问于2017-06-13得票数 0
我正在将数据添加到sqlalchemy。但有时数据不会更新或插入到数据库中。但是提交是成功的，我可以看到session对象的内存中的数据。即 session.identity_map 在sqlalchemy 1.3.3上运行。python 2.7。ubuntu 18.04 from sqlalchemy.orm import Session
from . import Errors as ExecuteErrors
class Errors(object):
def __init__(self, sqlalchemy_engine, d):
self.sqlalch
浏览 23提问于2019-05-29得票数 0
1回答
我希望使用Python将数千行插入到Oracle db中。为此，我尝试插入sqlalchemy会话的bulk_insert_mappings方法。下面是教程，它展示了如何快速地将csv文件加载到数据库中。我失败了，因为bulk_insert_mappings也期望一个映射器对象，而它们不会传递这个对象。
在没有csv的情况下创建连接和映射的代码：
from sqlalchemy.sql import select, sqltypes
from sqlalchemy.schema import CreateSchema
from sqlalchemy import create_engine,
浏览 9提问于2022-05-12得票数 0
1回答
我有一个字典，其中键名与sqlalchemy表/类的列名相同，后者称为类。
因此，我想我可以简单地使用以下代码来更新SQLalchemy类，然后将新更新的数据插入到SQL表中。
for key, value in d.items():
setattr(Series, key, value)
session.add(Series)
session.commit()
然而，这是行不通的，因为“系列”是一个类。因此，我想知道最有效的方法是将字典转换为sqlalchemy类，然后插入数据库。
我更希望该方法将遍历字典中的每个单独的键，然后更新sql-炼金术类，因为有时会缺少将Null值插入到
浏览 0提问于2019-04-03得票数 1
回答已采纳
我试图将几何数据插入数据库，但它不起作用。我创建了一个几何模型类，但如果它是对的，我现在就不这样做了。
几何类：
from datetime import datetime
from sqlalchemy import and_
from sqlalchemy import Column
from sqlalchemy import create_engine
from sqlalchemy import DateTime
from sqlalchemy import Float
from sqlalchemy import ForeignKey
from sqlalchemy import
浏览 2提问于2020-11-04得票数 1
回答已采纳
我试图使用原始sqlalchemy Postgres11查询将值插入到text()数据库中。当我通过psql客户机运行以下SQL查询时，它工作正常：
WITH a AS (
INSERT INTO person (id)
VALUES ('a')
RETURNING id
)
INSERT INTO person_info (person_id)
SELECT id
FROM a;
正确插入所有行：
# select id from person;
id
----
a
(1 row)
但是，如果我在sqlalche
浏览 3提问于2020-01-12得票数 1
回答已采纳
1回答
我正在尝试连接到一个数据库，并使用sqlalchemy插入到其中。我已经成功地使用pyodbc连接到了数据库，但是sqlalchemy给我带来了麻烦。 我使用sqlalchemy，这样我就可以使用pd.to_sql方法将数据帧插入到数据库中。 我检查了我计算机上的sql版本与数据库是否匹配。我还将数据库添加到我的计算机上的"odbc数据源“中。 我还确保所有凭据都是正确的，并将版本添加到连接url中的sql驱动程序中。 import sqlalchemy
connect_url = sqlalchemy.engine.url.URL(
'mssql+pyodbc&#
浏览 19提问于2019-05-14得票数 0
1回答
将数据插入AWS红移
、、、、
我想要将一个大型excel表数据加载到AWS中，使用Python需要很长时间来加载，所以我尝试使用Sqlalchemy。但是redshift-sqlalchemy文档是令人困惑的。所以我想使用普通的Sqlalchemy库。下面的代码可以从AWS红移中提取数据，我不知道如何修改它以将数据插入红移。如果可能的话，我喜欢立即插入数据。
import pandas as pd
import psycopg2
from sqlalchemy import create_engine
from sqlalchemy import text
sql = """
SELECT top
浏览 1提问于2022-09-23得票数 1
回答已采纳
SQLalchemy是两个包合二为一；核心和对象模型。ORM是建立在SQLalchemy之上的。 例如，我从一个API接收数据，然后通过SQLalchemy将其插入到SQL数据库中。我应该使用Core还是ORM？什么时候使用一种比另一种更好？
浏览 43提问于2020-07-10得票数 0
我正在尝试使用SQLAlchemy将数据插入MariaDB数据库。我正在解析一个XML文件，以获得需要插入的数据。我在读取数据时没有问题。有关此错误的许多问题，例如此python 3.2 UnicodeEncodeError: 'charmap' codec can't encode character '\u2013' in position 9629: character maps to ，都是指从文件中读取数据。然而，我在这一步得到了错误， con_string = db_driver + '://' + db_user + &#
浏览 33提问于2021-11-12得票数 1
回答已采纳
我的应用程序运行正常。只有doctest不起作用。
在应用程序中，我使用了一个模式
from models import db
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://..."
db.init_app(app)
...
if __name__ == '__main__':
app.run(debug=True, host='0.0.0.0', threaded=True)
我有几个非常简单的文档测试。在从Flask
浏览 3提问于2017-08-24得票数 1
我想从python字典中将数据插入到表中。但是我的字典包含的键比表中的列多。所以我在插入时得到了错误的sqlalchemy.exc.CompileError: Unconsumed column names: column_name。我只想插入表中存在的列名，而忽略额外的列。
如何用金刚炼金术做这件事？
我使用的代码是
from sqlalchemy import *
from sqlalchemy.dialects import postgresql
db = create_engine('postgresql+psycopg2://localhost:5432/postgres&
浏览 9提问于2021-05-17得票数 3
回答已采纳
我用的是酒瓶SqlAlchemy。我将数据插入到Postgres中，并且有一个JSON列类型。当没有数据时，我返回None，目的是将NULL设置到列中。这就是建议的。
if someCondition:
json_obj = json.dumps(my_dict)
return json_obj
else:
return None # this inserts a 'null' string incorrectly
# Only this works correctly:
return null() # imported from sql
浏览 6提问于2022-04-07得票数 3
回答已采纳
我正在尝试将一条记录插入到远程数据库的mysql表中。python可以工作(没有错误)，但我的插入都没有反映在远程数据库中。SQLAlchemy似乎维护了一个缓存，并且正在更新它，而不是推送它。我甚至把表放在服务器上，SQLAlchemy仍然认为它是存在的。
我不使用Session或以其他方式提交事务，尽管当我回显语句时，似乎正在发生提交。
SQLAlchemy是否维护某种缓存？
from sqlalchemy import MetaData
from sqlalchemy import Table
from sqlalchemy import create_engine
db_engine
浏览 0提问于2019-01-31得票数 0
我试图用sql炼金术将一行插入到mysql数据库的表中，但是当我插入并转到数据库时--检查数据--我什么也看不见。
这是我的密码：
从sqlalchemy导入表导入create_engine，从sqlalchemy.sql导入表导入MetaData，从sqlalchemy.orm导入会话生成器中选择、更新、插入
engine = create_engine(
"mysql://user:password@host/schema")
connection = engine.connect()
metadata = MetaData(bind=engine)
pric
浏览 2提问于2017-07-28得票数 0
2回答
我想将字符串列表批量插入到具有SQLAlchemy核心的MySQL数据库中。
engine = create_engine("mysql+mysqlconnector://...")
meta = MetaData()
meta.bind = engine
我的表格布局是这样的-加上两个当前未使用的列(不相关的1/2)：
MyTabe = Table('MyTable', meta,
Column('id', Integer, primary_key=True),
Column('color', Text),
Column(&#
浏览 2提问于2013-09-10得票数 21
回答已采纳
我正在尝试将xlsx文件中的数据插入mysqdl表中。我想在表中插入数据，如果主键上有重复，我想更新现有数据，否则就插入。我已经写了脚本，但我意识到它太多的工作，使用熊猫它很快。我怎样才能在熊猫身上实现它呢？
#!/usr/bin/env python3
import pandas as pd
import sqlalchemy
engine_str = 'mysql+pymysql://admin:mypass@localhost/mydb'
engine = sqlalchemy.create_engine(engine_str, echo=False, encodin
浏览 4提问于2016-10-25得票数 4
回答已采纳
目前，我正在尝试使用sqlalchemy创建一个postGIS数据库。我计划通过为要上传的shapefile数据制作几个表来规范化我的数据库。我的代码如下： from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, BigInteger, DateTime, MetaData
from geoalchemy2 import Geometry
Base = declara
浏览 28提问于2019-01-26得票数 1
回答已采纳
我在SqlAlchemy中使用SqlAlchemy将数据插入到带有UniqueConstraint的表中，这对于几个列来说是常见的，例如，我的ORM类具有以下内容：
UniqueConstraint("attr_1", "attr_2", "attr_3", name="attributes_uix")
我是否应该使用filter或filter_by结合_and来检查，我将要插入的数据是否会违反这个唯一的约束，或者它是通过try - except构造捕获IntegrityError的正确方法？
浏览 5提问于2015-10-30得票数 0
回答已采纳
我正在尝试动态创建表，并使用sqlAlchemy将CSV数据插入其中。
给定一组CSV：
FirstName, LastName
Mike, Myers
Ted,Stevens
和
name, city, district
Mike, london, waterloo
Ted, london, tower bridge
我有基于CSV头创建表和列的代码：
import sqlalchemy
import csv
from sqlalchemy import create_engine
from sqlalchemy import Table, Column, Integer, String,
浏览 0提问于2019-05-10得票数 0
使用下面的代码连接到postgres将我连接到默认的公共模式。我可以在连接字符串中的哪里提到模式名称？我正在尝试插入数据。所以当我使用dataframe.to_sql('myschema.mytable', engine, if_exists='append', index=False)时
它在公共模式中创建一个带有myschema.mytable的表名，而不是将数据插入到myschema下已经存在的mytable中。
我正在使用python中的sqlalchemy库。下面是我的连接字符串。
engine = create_engine('postgre
浏览 3提问于2020-03-24得票数 0
1回答
的情况：
我有一个烧瓶应用程序，在这个应用程序中，我需要使用主键将一行插入数据库的功能。
代码：
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = "postgresql://example:example@example:5432/example"
db = SQLAlchemy()
db.init_app(app)
class TestModel(d
浏览 1提问于2021-10-26得票数 0
我正在尝试将csv大容量插入到SQL server中的表中。问题是，数据与目标表的列不匹配。目标表有几个在源文件中找不到的审计列。我找到的解决方案是将其插入到视图中。代码非常简单：
from sqlalchemy import create_engine
engine = create_engine('mssql+pyodbc://[DNS]')
conn = engine.connect()
sql = "BULK INSERT [table view] FROM '[source file path]' WITH (FIELDTERMINATOR =
浏览 5提问于2017-10-20得票数 1
回答已采纳
我在SQLAlchemy中有以下列：
name = Column(String(36))
uuid= Column(String(36))
插入查询示例：
new_request = Project(name = names)
db_session.add(new_request)
db_session.commit()
我已经在数据库中为uuid设置了默认值。
但是SQLAlchemy在查询中设置了uuid=None，所以默认值不是生成值。
如何避免默认的null插入。
浏览 2提问于2019-07-02得票数 1
1回答
如何获得此SQL查询的等效SQLAlchemy语句？
select CONVERT(blobby USING utf8) as blobby from myTable where CONVERT(blobby USING utf8)="Hello";
blob是一个blob类型的字段，必须将其解压到字符串中。
我试过这个
DBSession.query(myTable).filter(myTable.blobby.encode(utf-8)="Hello").first()
但不起作用。给出一个奇怪的错误
AttributeError: Neither '
浏览 2提问于2015-02-25得票数 0
你好，我是SQLalchemy的新手，在列中插入数据时遇到了一些问题。
import sqlalchemy
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, ForeignKey, Boolean
from sqlalchemy.orm import relation
浏览 0提问于2013-03-01得票数 2
回答已采纳
我正在使用引用完整性规则将几个10k记录插入到数据库中。不幸的是，有些数据行是重复的(因为它们已经存在于数据库中)。在插入之前检查数据库中是否存在每一行的开销太大了，所以我打算继续处理由SQLAlchemy抛出的IntegrityError异常，记录错误，然后继续。
我的代码将如下所示：
# establish connection to db etc.
tbl = obtain_binding_to_sqlalchemy_orm()
datarows = load_rows_to_import()
try:
conn.execute(tbl.insert(), datarows)
浏览 0提问于2012-05-14得票数 10
回答已采纳
使用SQLAlchemy ORM，我希望确保值的列类型正确。
例如，假设我有一个Integer列。我尝试插入值“hello”，它不是一个有效的整数。SQLAlchemy将允许我这样做。直到后来，当我执行session.commit()时，它才会引发异常：sqlalchemy.exc.DataError: (DataError) invalid input syntax integer: "hello"…。
我正在添加成批的记录，出于性能原因，我不想在每个add(…)之后都提交。
那么我该如何：
只要我这样做，就会引发异常。在将插入的值添加到batch？之前，请确保插入的值可以转
浏览 72提问于2012-01-24得票数 22
回答已采纳
我希望使用PostgreSQL将包含列表的Python作为HSTORE对象存储在SQLAlchemy数据库中。跟着我的课桌。
from sqlalchemy.dialects.postgresql import HSTORE
from sqlalchemy import Column, String
from sqlalchemy.ext.declarative import declarative_base
Base = declarative_base()
class Data(Base):
id = Column(String, primary_key=True)
d
浏览 0提问于2021-10-15得票数 1
回答已采纳
我在Google Cloud Platform上的App Engine中有一段Python代码，它从Firebase获取数据并将其格式化为元组列表，其中每一行指定数据库的一行。我想将此数据插入到Cloud SQL for MySQL中。我已经生成了一个云服务帐户，并且还使用sqlalchemy将其连接到我的Cloud SQL for MySQL，但我无法理解如何将行插入到Cloud SQL。 我已经使用了Cloud SQL网站上的以下代码，并替换了所需的元素，但是如何插入到Cloud SQL for MySQL中？ db = sqlalchemy.create_engine(
# E
浏览 17提问于2020-01-28得票数 0
2回答
我正在使用sqlAlchemy与postgres数据库进行交互。这一切都被设置为可以插入字符串数据。我收到的数据通常是utf-8，并且设置工作得很好。作为一种边缘情况，最近出现了somedata\xtrailingdata格式的数据。
SQLAlchemy正试图通过somedata完全剥离\x之后的所有内容来进入此条目。
你能告诉我是否有一种方法可以指示SQLAlchemy只尝试插入整个代码而不是删除unicode部分。
我尝试过create_engine(dbUri, convert_unicode=True, client_encoding='utf8')
create_e
浏览 0提问于2015-11-12得票数 0
我有一个金字塔/ SQLAlchemy，MySQL python应用程序。当我执行原始SQL INSERT查询时，不会向DB写入任何内容。然而，在使用ORM时，我可以写到DB。我读了博士，我读了关于ZopeTransactionExtension的文章，读了很多这样的问题，都没有用。到目前为止还没有起作用的是：
transaction.commit() -没有任何东西写到数据库中。我确实意识到这句话在ZopeTransactionExtension中是必要的，但它在这里并没有神奇之处。
dbsession().commit -不起作用，因为我用的是ZopeTransactionEx
浏览 4提问于2014-08-25得票数 5
回答已采纳
在Python中，使用SQLAlchemy，我想插入或更新一行。我试过这个：
existing = db.session.query(Toner)
for row in data:
new = Toner(row[0], row[1], row[2])
它不起作用。如何在Toner表中插入或更新new？我怀疑这是用merge完成的，但我不明白如何做到这一点。
浏览 1提问于2011-10-25得票数 63
我正在处理Python3.5服务器项目，并使用SQLAlchemy 1.0.12和cx_Oracle 5.2.1将数据插入到Oracle11g中。我注意到，我的许多多行表插入都间歇性地失败，出现了"ORA-01458:变量字符串中的无效长度“错误。
我通常一次插入几千到数万行，数据主要由字符串、Pandas时间戳和浮点数组成。我提出以下意见：
此错误发生在Python服务器的Windows和Linux主机操作系统上。
即使数据没有变化，错误也会间歇性地发生
如果我不插入浮点数，或者对它们进行舍入，错误就不会经常发生，但仍然会发生。
如果我一次只插入一行，就不会遇到错误(
浏览 6提问于2016-09-17得票数 2
我使用的是SQLALchemy 1.2.0b1版
我的桌子看起来像这样
class Company(Base):
__tablename__ = 'company'
id = Column(Integer, primary_key=True, autoincrement=True)
cik = Column(String(10), nullable=False, index=True, unique=True)
name = Column(String(71), nullable=False)
当我向表中插入新值时，我确实指定了
company=
浏览 7提问于2017-07-24得票数 3
我尝试使用SqlAlchemy在数据库中以日期格式插入数据，问题是当我检查数据库时，只有空值。 如何使用python/SqlAlchemy将时间戳数据插入到MySQL数据库中。 AttributeError：“Timestamp”对象没有“”translate“”属性。“” 数据 import numpy as np
import pandas as pd
import sqlalchemy as db
from sqlalchemy import create_engine
import pymysql
import MySQLdb
import json
import datetim
浏览 24提问于2020-01-14得票数 1
回答已采纳
我有一个包含一张工作表的excel文件。它包含两列num1和num2，并且这两列都有整数值。我正在尝试使用Sqlalchemy和pandas将这些数据提取并插入到Mysql数据库中。
from sqlalchemy import create_engine, MetaData,Column,Integer
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker,validates
import pandas as pd
Base = declarative_
浏览 1提问于2017-09-21得票数 3
2回答
读取csv并插入数据库性能
、、、、
我的任务是逐行读取csv文件并将它们插入数据库。
csv文件包含大约170万行。
我使用python和sqlalchemy (合并函数)来完成这个任务。但它花了五个多小时。
它是由python慢性能还是sqlalchemy还是sqlalchemy造成的？
或者，如果我用金刚来做它，以使一个明显的更好的表现？(但我没有经验。)此外，这项工作每个月都需要安排)
希望你能提出建议，谢谢！
更新:数据库- mysql
浏览 8提问于2016-03-22得票数 0
我希望使用带有Postgres数据库的SQLAlchemy将行从一个表移到另一个表(关于堆栈溢出，关于移动数据还有其他问题，但这些问题并不集中于使用SQLAlchemy )。
方法是将DELETE与RETURNING结合使用，并将行插入到另一个表中。
我使用的是: SQLAlchemy 1.0.12、Postgres 9.4和Python2.7.11。
设置表
以下SQL创建表并插入一行数据：
create table example1 (
id integer,
value_a integer,
value_b integer,
CONSTRAINT exam
浏览 5提问于2016-02-19得票数 0
回答已采纳
使用sqlalchemy将数据插入到数据库中非常容易。
address.name = 'Joe'
address.age = 26
session.add(address)
但实际上我有三个表--我如何指定我想要插入数据的表？
浏览 1提问于2012-11-03得票数 6
回答已采纳
使用SQLAlchemy反射，如何在表中插入/更新数据？
我刚刚了解了如何使用SQLAlchemy反射作为来查询特定表。我已经完成了对数据的手动修改，现在我想保存到数据库中，但我不知道如何保存。这是我到目前为止尝试过的方法。
class Member(Base):
__table__ = Table('member', Metadata, autoload=True)
def set_password(self, member_id, password):
data = None
for data in session.add(
浏览 1提问于2013-03-08得票数 1
回答已采纳
1回答
我正在运行一个应用程序，使用sqlalchemy来访问数据库层。现在我需要得到所有的插入，更新，删除操作，我在两个不同的地方写了db操作，看起来更改这些代码是非常危险的。有没有什么办法可以让我只修改sqlalchemy的代码并捕获所有的“插入、更新、删除”操作？
我试图找到execute，但是有太多的定义：
lib/python2.6/site-packages/SQLAlchemy-0.5.3-py2.6.egg/sqlalchemy/engine/base.py
463: def execute(self, *multiparams, **params):
500: def e
浏览 0提问于2011-12-07得票数 0
回答已采纳
这是我第一次使用sqlalchemy和大熊猫在点击库中插入一些数据。
当我尝试使用clickhouse cli插入一些数据时，它工作得很好，但是当我尝试使用sqlalchemy做同样的事情时，我不知道为什么会缺少一行。
我做错什么了吗？
import pandas as pd
# created the dataframe
engine = create_engine(uri)
session = make_session(engine)
metadata = MetaData(bind=engine)
metadata.reflect(bind = engine)
conn = engin
浏览 0提问于2018-12-26得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
