大连爱普生农业科技有限公司
User Avatar

青岛网站建设公司番禺网站建设

大连爱普生农业科技有限公司 2026/09/09 20:08:34

关于数据库迁移


什么是数据库迁移


数据库迁移（Database Migration）是指对数据库结构进行版本控制的过程，它允许开发团队跟踪数据库模式的变更，并确保在不同环境（开发、测试、生产）中数据库结构的一致性。

为什么需要数据库迁移


在传统的软件开发中，数据库变更通常通过手动执行SQL脚本完成，这种方式存在诸多问题：

版本不一致：不同环境的数据库结构可能不一致

协作困难：多人开发时容易产生冲突

回滚复杂：出现问题时难以快速回滚到之前的版本

缺乏历史记录：无法追踪数据库结构的变更历史

Liquibase

Liquibase 是一个开源的数据库迁移工具，它通过 changelog 文件来管理数据库的变更，支持多种格式（XML、JSON、YAML、SQL）的变更定义，能够与多种数据库系统协同工作。

主要特性：

支持多种数据库（MySQL、PostgreSQL、Oracle等）

多种变更定义格式

回滚支持

与Spring Boot无缝集成

丰富的变更类型支持

Spring Boot 集成 Liquibase

添加依赖

首先，在pom.xml中添加 Liquibase 依赖：

<!-- Liquibase Database Migration --> <dependency> <groupId>org.liquibase</groupId> <artifactId>liquibase-core</artifactId> </dependency>

Liquibase比起Flyway，对Springboot的支持更好。使用Springboot3也可以运行，Flyway则在Springboot3里面无法使用。

YML配置

# Liquibase Configuration liquibase: enabled: true change-log: classpath:db/changelog/db.changelog-master.xml drop-first: false default-schema: mqtt

定义Liquibase的XML

创建主变更日志文件

在src/main/resources/db/changelog目录下创建主变更日志文件db.changelog-master.yaml：

<?xml version="1.0" encoding="UTF-8"?> <databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.20.xsd"> <!-- Include all changelog files --> <include file="db/changelog/changes/v1.0-initial-schema.xml"/> <include file="db/changelog/changes/v1.1-sample-data.xml"/> </databaseChangeLog>

v1.0-initial-schema.xml 初始化数据库结构

<?xml version="1.0" encoding="UTF-8"?> <databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.20.xsd"> <!-- Create mqtt_connection table --> <changeSet id="1" author="mqtt-websocket-bridge"> <createTable tableName="mqtt_connection" remarks="MQTT Connection Table"> <column name="id" type="BIGINT" autoIncrement="true"> <constraints primaryKey="true" nullable="false"/> </column> <column name="client_id" type="VARCHAR(255)" remarks="MQTT Client ID"> <constraints nullable="false" unique="true"/> </column> <column name="broker_url" type="VARCHAR(255)" remarks="MQTT Broker URL"> <constraints nullable="false"/> </column> <column name="username" type="VARCHAR(255)" remarks="Username"/> <column name="password" type="VARCHAR(255)" remarks="Password"/> <column name="keep_alive" type="INT" defaultValue="60" remarks="Keep Alive Interval (seconds)"/> <column name="clean_session" type="TINYINT(1)" defaultValue="1" remarks="Clean Session Flag"/> <column name="protocol_version" type="VARCHAR(50)" defaultValue="MQTT 3.1.1" remarks="Protocol Version"/> <column name="tls_enabled" type="TINYINT(1)" defaultValue="0" remarks="TLS Enabled"/> <column name="status" type="INT" defaultValue="0" remarks="Connection Status (0: disconnected, 1: connected)"/> <column name="connected_at" type="DATETIME" remarks="Connection Timestamp"/> <column name="disconnected_at" type="DATETIME" remarks="Disconnection Timestamp"/> <column name="created_at" type="DATETIME" defaultValueComputed="CURRENT_TIMESTAMP" remarks="Create Time"/> <column name="updated_at" type="DATETIME" defaultValueComputed="CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP" remarks="Update Time"/> <column name="deleted" type="INT" defaultValue="0" remarks="Logical Delete Flag"/> </createTable> <!-- Create indexes for mqtt_connection --> <createIndex indexName="idx_client_id" tableName="mqtt_connection"> <column name="client_id"/> </createIndex> <createIndex indexName="idx_status" tableName="mqtt_connection"> <column name="status"/> </createIndex> <createIndex indexName="idx_created_at" tableName="mqtt_connection"> <column name="created_at"/> </createIndex> </changeSet> <!-- Create mqtt_subscription table --> <changeSet id="2" author="mqtt-websocket-bridge"> <createTable tableName="mqtt_subscription" remarks="MQTT Subscription Table"> <column name="id" type="BIGINT" autoIncrement="true"> <constraints primaryKey="true" nullable="false"/> </column> <column name="client_id" type="VARCHAR(255)" remarks="MQTT Client ID"> <constraints nullable="false"/> </column> <column name="topic" type="VARCHAR(500)" remarks="MQTT Topic"> <constraints nullable="false"/> </column> <column name="qos" type="INT" defaultValue="0" remarks="Quality of Service (0, 1, 2)"/> <column name="subscribed_at" type="DATETIME" defaultValueComputed="CURRENT_TIMESTAMP" remarks="Subscription Timestamp"/> <column name="created_at" type="DATETIME" defaultValueComputed="CURRENT_TIMESTAMP" remarks="Create Time"/> <column name="updated_at" type="DATETIME" defaultValueComputed="CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP" remarks="Update Time"/> <column name="deleted" type="INT" defaultValue="0" remarks="Logical Delete Flag"/> </createTable> <!-- Create indexes for mqtt_subscription --> <createIndex indexName="idx_client_id" tableName="mqtt_subscription"> <column name="client_id"/> </createIndex> <createIndex indexName="idx_topic" tableName="mqtt_subscription"> <column name="topic"/> </createIndex> <createIndex indexName="idx_subscribed_at" tableName="mqtt_subscription"> <column name="subscribed_at"/> </createIndex> <!-- Create unique constraint --> <addUniqueConstraint tableName="mqtt_subscription" columnNames="client_id, topic" constraintName="uk_client_topic"/> </changeSet> <!-- Create mqtt_message table --> <changeSet id="3" author="mqtt-websocket-bridge"> <createTable tableName="mqtt_message" remarks="MQTT Message Table"> <column name="id" type="BIGINT" autoIncrement="true"> <constraints primaryKey="true" nullable="false"/> </column> <column name="client_id" type="VARCHAR(255)" remarks="MQTT Client ID"> <constraints nullable="false"/> </column> <column name="topic" type="VARCHAR(500)" remarks="MQTT Topic"> <constraints nullable="false"/> </column> <column name="payload" type="TEXT" remarks="Message Payload"/> <column name="qos" type="INT" defaultValue="0" remarks="Quality of Service (0, 1, 2)"/> <column name="retained" type="TINYINT(1)" defaultValue="0" remarks="Retained Message Flag"/> <column name="direction" type="VARCHAR(50)" remarks="Message Direction (INBOUND, OUTBOUND)"> <constraints nullable="false"/> </column> <column name="created_at" type="DATETIME" defaultValueComputed="CURRENT_TIMESTAMP" remarks="Create Time"/> <column name="deleted" type="INT" defaultValue="0" remarks="Logical Delete Flag"/> </createTable> <!-- Create indexes for mqtt_message --> <createIndex indexName="idx_client_id" tableName="mqtt_message"> <column name="client_id"/> </createIndex> <createIndex indexName="idx_topic" tableName="mqtt_message"> <column name="topic"/> </createIndex> <createIndex indexName="idx_direction" tableName="mqtt_message"> <column name="direction"/> </createIndex> <createIndex indexName="idx_created_at" tableName="mqtt_message"> <column name="created_at"/> </createIndex> </changeSet> </databaseChangeLog>

v1.1-sample-data.xml 初始化数据

<?xml version="1.0" encoding="UTF-8"?> <databaseChangeLog xmlns="http://www.liquibase.org/xml/ns/dbchangelog" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.20.xsd"> <!-- Insert sample connection data --> <changeSet id="4" author="mqtt-websocket-bridge"> <insert tableName="mqtt_connection"> <column name="client_id" value="emqx_NJEONID"/> <column name="broker_url" value="tcp://localhost:1883"/> <column name="username" value=""/> <column name="password" value=""/> <column name="keep_alive" valueNumeric="60"/> <column name="clean_session" valueNumeric="1"/> <column name="protocol_version" value="MQTT 5"/> <column name="status" valueNumeric="0"/> </insert> </changeSet> </databaseChangeLog>
版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈，一经查实，立即删除！

网站建设策划书潜江网站建设

Qwen3-VL提取UltraISO注册码信息（教学场景展示）在日常软件使用中，我们常会遇到需要从一张截图里“读出”注册码的场景——比如帮助同事找回丢失的激活

2026/06/30 12:29:01

辽宁网站建设恩施网站建设

蓝奏云桌面客户端：告别浏览器限制的终极文件管理方案【免费下载链接】lanzou-gui蓝奏云 | 蓝奏云客户端 | 蓝奏网盘 GUI版本项目地址: https://gitcode.com

2026/06/30 10:12:18

旅游网站建设绍兴网站建设

全功能应用：拼写检查与索引生成在文本处理领域，拼写检查和索引生成是两项重要的任务。下面将详细介绍如何使用相关工具和脚本完成这些任务。拼写检查脚本拼写检查脚本通过设置一个 shell 变量AWKLIB来

2026/06/30 10:15:19

怎样建设网站网站建设规划

Qwen3-VL与镜像级授权机制的技术融合探索在人工智能模型日益复杂、部署场景愈发多样的今天，如何将一个强大的视觉语言模型安全、稳定地交付到最终用户手中，已成为AI产品化过

2026/06/30 12:19:00

网站建设方案大庆网站建设

命令行下载工具深度解析：curl与wget实战指南【免费下载链接】Bash-OnelinerA collection of handy Bash One-Liners and termi

2026/06/30 14:15:09

房地产网站建设南充网站建设

第一章：Open-AutoGLM公文写作革命的背景与意义在数字化政府与智能办公快速发展的背景下，传统公文处理模式面临效率低下、格式不统一、人工撰写耗时等痛点。Open-Au

2026/06/30 13:17:35

广州市网站建设安徽网站建设

游戏本地化破解研究：HunyuanOCR提取未汉化游戏内文本资源在Steam上发现一款画风惊艳的日式RPG，点开商店页面却赫然写着“不支持中文”——这种场景对国内玩家来说早

2026/06/30 10:47:52

深圳网站建设网站建设方案书

随着互联网技术的快速发展，心理学与计算机科学的结合为人们提供了更便捷的自我认知途径。本系统基于Java语言与Spring Boot框架开发，结合MySQL数据库࿰

2026/06/30 13:06:04

医院网站建设方案陕西网站建设

计算机毕业设计springboot家庭财务管理系统28si49 （配套有源码 程序 mysql数据库 论文）本套源码可以在文本联xi,先看具体系统功能演示视频领取ÿ

2026/06/30 12:17:31

物流网站建设广东网站建设

音乐喷泉博途v14和mcgs7.7触摸屏程序资料包2，带运行效果视频，流程图和io表最近在研究自动化控制项目时，发现了一款超有趣的资料包——音乐喷泉博途V14

2026/06/30 11:20:24