博客
关于我
利用 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/

    你可能感兴趣的文章
    PostGIS中获取所有EPSG的编码以及对应Proj4字符串
    查看>>
    PostGIS在Windows上的下载与安装
    查看>>
    postgis数据库优化_postgresql 性能优化
    查看>>
    Postgres Docker版本安装mysql_fdw 插件
    查看>>
    Postgres invalid command \N数据恢复处理
    查看>>
    Postgres like 模糊查询匹配集合
    查看>>
    Postgres 自定义函数内实现 in 操作符的递归查询
    查看>>
    Postgres 返回当前时间前后指定天数的集合
    查看>>
    postgres--vacuum
    查看>>
    postgres--wal
    查看>>
    postgres--流复制
    查看>>
    postgres10配置huge_pages
    查看>>
    PostgreSQL 10.0 preview 变化 - pg_xlog,pg_clog,pg_log目录更名为pg_wal,pg_xact,log
    查看>>
    PostgreSQL 10.1 手册_部分 II. SQL 语言_第 15章 并行查询_15.2. 何时会用到并行查询?...
    查看>>
    PostgreSQL 10.1 手册_部分 II. SQL 语言_第 9 章 函数和操作符_9.23. 行和数组比较
    查看>>
    PostgreSQL 10.1 手册_部分 III. 服务器管理_第 21 章 数据库角色
    查看>>
    Postgresql 12.9如何配置允许远程连接
    查看>>
    PostgreSQL 9.6 同步多副本 与 remote_apply事务同步级别 应用场景分析
    查看>>
    Postgresql CopyManager 流式批量数据入库
    查看>>
    PostgreSQL cube 插件 - 多维空间对象
    查看>>