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

    你可能感兴趣的文章
    PHP $_SERVER['HTTP_REFERER'] 获取前一页面的 URL 地址
    查看>>
    php & 和 & (主要是url 问题)
    查看>>
    php -- 魔术方法 之 判断属性是否存在或为空:__isset()
    查看>>
    php -- 魔术方法 之 获取属性:__get()
    查看>>
    php -树-二叉树的实现
    查看>>
    PHP -算法-二路归并
    查看>>
    php 2条不一样 的json数据 怎么放在一个json里面_如果你是PHP开发者,请务必了解一下Composer...
    查看>>
    php 360 不记住密码,JavaScript_多种方法实现360浏览器下禁止自动填写用户名密码,目前开发一个项目遇到一个很 - phpStudy...
    查看>>
    regExp的match、exec、test区别
    查看>>
    php 404 自定义,APACHE 自定义404错误页面设置方法
    查看>>
    PHP 5.3.0以上推荐使用mysqlnd驱动
    查看>>
    php 7.2 安装 mcrypt 扩展: mcrypt 扩展从 php 7.1.0 开始废弃;自 php 7.2.0 起,会移到 pecl...
    查看>>
    php aes sha1解密,PHP AES加密/解密
    查看>>
    php CI框架单个file表单多文件上传例子
    查看>>
    php composer
    查看>>
    reflow和repaint引发的性能问题
    查看>>
    php csv 导出
    查看>>
    php curl 实例+详解
    查看>>
    php curl_init函数用法(http://blog.sina.com.cn/s/blog_640738130100tsig.html)
    查看>>
    php curl_multi批量发送http请求
    查看>>