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

    你可能感兴趣的文章
    Oracle 在Sqlplus 执行sql脚本文件。
    查看>>
    Oracle 如何处理CLOB字段
    查看>>
    oracle 学习
    查看>>
    oracle 定义双重循环例子
    查看>>
    ORACLE 客户端工具连接oracle 12504
    查看>>
    Oracle 客户端连接时报ORA-01019错误总结
    查看>>
    oracle 嵌套表 例子,Oracle之嵌套表(了解)
    查看>>
    Oracle 常用命令
    查看>>
    Oracle 常用的V$视图脚本(二)
    查看>>
    Oracle 并行原理与示例总结
    查看>>
    oracle 并集 时间_Oracle集合运算符 交集 并集 差集
    查看>>
    Oracle 序列sequence 开始于某个值(10)执行完nextval 发现查出的值比10还小的解释
    查看>>
    oracle 执行一条查询语句,把数据加载到页面或者前台发生的事情
    查看>>
    oracle 批量生成建同义词语句和付权语句
    查看>>
    oracle 抓包工具,shell 安装oracle和pfring(抓包) 及自动环境配置
    查看>>
    Oracle 拆分以逗号分隔的字符串为多行数据
    查看>>
    Oracle 排序中使用nulls first 或者nulls last 语法
    查看>>
    oracle 插入date日期类型的数据、插入从表中查出的数据,使用表中的默认数据
    查看>>
    Oracle 操作笔记
    查看>>
    oracle 数据库 安装 和优化
    查看>>