博客
关于我
利用 SQLAlchemy 实现轻量级数据库迁移
阅读量:686 次
发布时间:2019-03-17

本文共 2942 字,大约阅读时间需要 9 分钟。

lightweight database migration tools with python

in daily work, it's common to need to migrate data between different databases. here are some simple methods to consider:

copy data between databases

  • kettle's table copy wizard

    previously wrote a blog post about this: a simple guide to using kettle for database migrations.

  • use csv as intermediary

    requires time to process field data types and ensure data consistency.

  • utilize sqlalchemy

    wrote a blog post about this too: a step-by-step guide to using sqlalchemy for database migrations. the process involves creating models and manually mapping field types.

  • step-by-step database migration

    assuming you need to migrate the emp_master table from sql server to sqlite, follow these steps:

  • create the target database schema

    use sqlacodegen to generate sqlalchemy models based on the source database:

    sqlacodegen mssql+pymssql://user:pwd@localhost:1433/testdb > models.py --tables emp_master

    adjust the generated code manually to match your needs:

    # models.pyfrom sqlalchemy import Column, Integer, Stringfrom sqlalchemy.ext.declarative import declarative_baseBase = declarative_base()class EmpMaster(Base):    __tablename__ = 'emp_master'    emp_id = Column(Integer, primary_key=True)    gender = Column(String(10))    age = Column(Integer)    email = Column(String(50))    phone_nr = Column(String(20))    education = Column(String(20))    marital_stat = Column(String(20))    nr_of_children = Column(Integer)

    create the database and table using sqlalchemy:

    # create_schema.pyfrom sqlalchemy import create_enginefrom models import Baseengine = create_engine('sqlite:///employees.db')Base.metadata.create_all(engine)
  • migrate data using pandas

    read data from source database to a pandas dataframe and write it to the target database:

    # data_migrate.pyfrom sqlalchemy import create_engineimport pandas as pdsource_engine = create_engine('mssql+pymssql://user:pwd@localhost:1433/testdb')target_engine = create_engine('sqlite:///employees.db')df = pd.read_sql('emp_master', source_engine)df.to_sql('emp_master', target_engine, index=False, if_exists='replace')
  • advantages of using pandas for data migration

    pandas provides a convenient way to handle data transformation and export to various database formats. its read_sql() function simplifies data extraction from databases, while to_sql() handles the insertion process.

    why choose pandas for database migration

    pandas is lightweight and efficient for data migration tasks. it allows for quick data visualization and manipulation before storage in the target database.

    potential issues to address

    • ensure that data types are compatible between source and target databases.
    • handle null values and data validation to maintain data integrity.
    • test the migration process on a small dataset before applying it to the live database.

    by following these steps, you can efficiently migrate your database while minimizing risks and ensuring data consistency.

    转载地址:http://zjthz.baihongyu.com/

    你可能感兴趣的文章
    python | 深入理解Python并发编程中的GIL限制与解决方案
    查看>>
    Python | 爬虫实战——亚马逊搜索页监控(附详细源码)
    查看>>
    python | 高效使用Python工具自动生成模块文档的秘诀
    查看>>
    python 一个list去除另一个list中的值
    查看>>
    python 三大框架的 介绍。
    查看>>
    Python 下载的 11 种姿势,一种比一种高级!
    查看>>
    python读取一个文件夹下所有图片_初学Python-找出文件夹下的所有图片
    查看>>
    Python 中 3 个不可思议的返回功能
    查看>>
    python 中 dict 的另一种用法
    查看>>
    Python 中 PIL 读取图片出现异常旋转的解决方法
    查看>>
    python读取word表格内容(1)
    查看>>
    python 中os.path.join 双斜杠的解决办法
    查看>>
    python 中PIL.Image和OpenCV图像格式相互转换
    查看>>
    Python 中Semaphore 信号量对象、Event事件、Condition
    查看>>
    python 中with的使用及样例
    查看>>
    python读取wav文件并播放[pyaudio/wave]
    查看>>
    python读取txt文件的行数
    查看>>
    Python 中内置的最大堆 API
    查看>>
    Python 中只有一个 True 和一个 False 对象吗?
    查看>>
    python读取mtcars数据集并实现以下操作_关于数据处理。。,Python交流,技术交流区,鱼C论坛 - Powered by Discuz!...
    查看>>