PostgreSQL数据库升级的完整流程与注意事项

# 查看当前 PostgreSQL 版本
psql -c "SELECT version();"
# 查看数据目录位置
psql -c "SHOW data_directory;"
# 查看安装路径
which pg_ctl

# 使用 pg_basebackup 创建基础备份
pg_basebackup -h localhost -U replicator -D /backup/pg_basebackup_$(date +%Y%m%d) -Ft -z -P

# 全库逻辑备份（推荐用于中小型数据库）
pg_dumpall -h localhost -U postgres -f /backup/full_backup_$(date +%Y%m%d).sql

# Ubuntu/Debian 示例
sudo apt update
sudo apt install postgresql-14 postgresql-client-14
# CentOS/RHEL 示例
sudo dnf install postgresql14-server postgresql14

# 通常安装包会自动初始化，若未初始化：
sudo -u postgres /usr/pgsql-14/bin/initdb -D /var/lib/pgsql/14/data

sudo systemctl stop postgresql-13

sudo -u postgres /usr/pgsql-14/bin/pg_upgrade \
    --old-bindir=/usr/pgsql-13/bin \
    --new-bindir=/usr/pgsql-14/bin \
    --old-datadir=/var/lib/pgsql/13/data \
    --new-datadir=/var/lib/pgsql/14/data \
    --check

sudo -u postgres /usr/pgsql-14/bin/pg_upgrade \
    --old-bindir=/usr/pgsql-13/bin \
    --new-bindir=/usr/pgsql-14/bin \
    --old-datadir=/var/lib/pgsql/13/data \
    --new-datadir=/var/lib/pgsql/14/data \
    --link  # 使用硬链接加速（需同一文件系统）

sudo systemctl start postgresql-14
# 运行 pg_upgrade 生成的 analyze_new_cluster.sh
sudo -u postgres /var/lib/pgsql/14/data/analyze_new_cluster.sh

sudo apt install postgresql-14
sudo pg_ctlcluster 14 main start  # Debian/Ubuntu

# 导出为自定义格式（推荐，支持并行恢复）
pg_dump -h localhost -U postgres -Fc mydb > /backup/mydb.dump
# 或导出为纯 SQL（便于查看和修改）
pg_dump -h localhost -U postgres mydb > /backup/mydb.sql

CREATE DATABASE mydb;
CREATE USER myapp WITH PASSWORD 'secret';
GRANT ALL PRIVILEGES ON DATABASE mydb TO myapp;

# 自定义格式导入（支持并行）
pg_restore -h localhost -U postgres -d mydb -j 4 /backup/mydb.dump
# SQL 格式导入
psql -h localhost -U postgres -d mydb -f /backup/mydb.sql

SELECT name, default_version, installed_version FROM pg_available_extensions WHERE installed_version IS NOT NULL;

# Ubuntu 安装 PostGIS 3.3 for PostgreSQL 14
sudo apt install postgis postgresql-14-postgis-3
# 在数据库中启用
CREATE EXTENSION postgis;

-- 在新数据库中先创建旧版 PostGIS
CREATE EXTENSION postgis VERSION '3.2.0';

-- 然后升级到新版
ALTER EXTENSION postgis UPDATE TO '3.3.0';

-- 测试 PostGIS 函数
SELECT ST_AsText(ST_Point(1, 2));

<dependency>
    <groupId>org.postgresql</groupId>
    <artifactId>postgresql</artifactId>
    <version>42.6.0</version> <!-- 2023年最新版，支持 PG 15 -->
</dependency>

// 标准 JDBC 连接
String url = "jdbc:postgresql://localhost:5432/mydb";
Properties props = new Properties();
props.setProperty("user", "myapp");
props.setProperty("password", "secret");
props.setProperty("ssl", "false"); // 生产环境应启用 SSL
try (Connection conn = DriverManager.getConnection(url, props)) {
    System.out.println("Connected to PostgreSQL " + conn.getMetaData().getDatabaseProductVersion());
}

import org.junit.jupiter.api.Test;
import java.sql.*;
import static org.junit.jupiter.api.Assertions.*;
public class PostgreSqlUpgradeTest {
    private static final String DB_URL = "jdbc:postgresql://localhost:5432/testdb";
    private static final String USER = "testuser";
    private static final String PASS = "testpass";
    @Test
    public void testBasicCRUD() throws SQLException {
        try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS)) {
            // 创建测试表
            try (Statement stmt = conn.createStatement()) {
                stmt.execute("DROP TABLE IF EXISTS upgrade_test");
                stmt.execute("CREATE TABLE upgrade_test (id SERIAL PRIMARY KEY, name TEXT, created_at TIMESTAMP DEFAULT NOW())");
            }
            // 插入数据
            try (PreparedStatement pstmt = conn.prepareStatement(
                    "INSERT INTO upgrade_test (name) VALUES (?) RETURNING id")) {
                pstmt.setString(1, "Test Record");
                try (ResultSet rs = pstmt.executeQuery()) {
                    assertTrue(rs.next());
                    int id = rs.getInt("id");
                    assertTrue(id > 0);
                }
            }
            // 查询数据
            try (Statement stmt = conn.createStatement();
                 ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM upgrade_test")) {
                assertTrue(rs.next());
                assertEquals(1, rs.getInt(1));
            }
            // 更新数据
            try (PreparedStatement pstmt = conn.prepareStatement(
                    "UPDATE upgrade_test SET name = ? WHERE id = ?")) {
                pstmt.setString(1, "Updated Name");
                pstmt.setInt(2, 1);
                assertEquals(1, pstmt.executeUpdate());
            }
            // 删除数据
            try (Statement stmt = conn.createStatement()) {
                assertEquals(1, stmt.executeUpdate("DELETE FROM upgrade_test"));
            }
        }
    }
    @Test
    public void testJsonbSupport() throws SQLException {
        // 验证 JSONB 类型（PG 9.4+ 支持，但新版本有增强）
        try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
             Statement stmt = conn.createStatement()) {
            stmt.execute("DROP TABLE IF EXISTS json_test");
            stmt.execute("CREATE TABLE json_test (data JSONB)");
            stmt.execute("INSERT INTO json_test VALUES ('{\"key\": \"value\", \"num\": 42}')");
            try (ResultSet rs = stmt.executeQuery(
                    "SELECT data->>'key' as key_val, (data->>'num')::int as num_val FROM json_test")) {
                assertTrue(rs.next());
                assertEquals("value", rs.getString("key_val"));
                assertEquals(42, rs.getInt("num_val"));
            }
        }
    }
    @Test
    public void testPartitioning() throws SQLException {
        // 验证声明式分区（PG 10+ 引入，后续版本增强）
        try (Connection conn = DriverManager.getConnection(DB_URL, USER, PASS);
             Statement stmt = conn.createStatement()) {
            stmt.execute("DROP TABLE IF EXISTS sales");
            stmt.execute("""
                CREATE TABLE sales (
                    id SERIAL,
                    sale_date DATE NOT NULL,
                    amount NUMERIC
                ) PARTITION BY RANGE (sale_date)
                """);
            stmt.execute("""
                CREATE TABLE sales_2023 PARTITION OF sales
                FOR VALUES FROM ('2023-01-01') TO ('2024-01-01')
                """);
            stmt.execute("INSERT INTO sales (sale_date, amount) VALUES ('2023-06-15', 100.50)");
            try (ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM sales_2023")) {
                assertTrue(rs.next());
                assertEquals(1, rs.getInt(1));
            }
        }
    }
}

# log4j2.xml 片段
<Logger name="org.springframework.jdbc" level="DEBUG"/>
<Logger name="com.zaxxer.hikari" level="DEBUG"/>

-- 分析整个数据库
ANALYZE;
-- 或针对关键大表
ANALYZE VERBOSE large_table;

# 使用 pg_controldata 检查控制文件版本
pg_controldata /var/lib/pgsql/14/data
# 检查配置差异
diff /var/lib/pgsql/13/data/postgresql.conf /var/lib/pgsql/14/data/postgresql.conf

# SELinux 上下文修复（CentOS/RHEL）
sudo semanage fcontext -a -t postgresql_db_t "/var/lib/pgsql/14(/.*)?"
sudo restorecon -R /var/lib/pgsql/14
# AppArmor 配置（Ubuntu）
sudo nano /etc/apparmor.d/usr.sbin.postgresql-14
# 添加数据目录路径

-- 检查时区设置
SHOW timezone;
-- 测试时间转换
SELECT '2023-01-01 12:00:00+00'::timestamptz;

// 正确处理带时区的时间
OffsetDateTime odt = resultSet.getObject("created_at", OffsetDateTime.class);
LocalDateTime ldt = odt.toLocalDateTime(); // 转换为本地时间

-- 查看复制槽
SELECT * FROM pg_replication_slots;
-- 升级前暂停复制，升级后重建槽
SELECT pg_drop_replication_slot('my_slot');
-- 升级后
SELECT pg_create_logical_replication_slot('my_slot', 'pgoutput');

# 升级后运行
vacuumdb --all --analyze-in-stages

---
- name: PostgreSQL Major Version Upgrade
  hosts: db_servers
  become: yes
  vars:
    pg_old_version: "13"
    pg_new_version: "14"
    pg_data_dir_old: "/var/lib/pgsql/{{ pg_old_version }}/data"
    pg_data_dir_new: "/var/lib/pgsql/{{ pg_new_version }}/data"
  tasks:
    - name: Backup current database
      shell: pg_dumpall -U postgres > /backup/pg_full_{{ ansible_date_time.iso8601 }}.sql
      register: backup_result
    - name: Install new PostgreSQL version
      package:
        name: "postgresql-{{ pg_new_version }}"
        state: present
    - name: Initialize new cluster
      command: /usr/pgsql-{{ pg_new_version }}/bin/initdb -D {{ pg_data_dir_new }}
      args:
        creates: "{{ pg_data_dir_new }}/PG_VERSION"
    - name: Stop old cluster
      systemd:
        name: "postgresql-{{ pg_old_version }}"
        state: stopped
    - name: Run pg_upgrade check
      command: >
        /usr/pgsql-{{ pg_new_version }}/bin/pg_upgrade
        --old-bindir=/usr/pgsql-{{ pg_old_version }}/bin
        --new-bindir=/usr/pgsql-{{ pg_new_version }}/bin
        --old-datadir={{ pg_data_dir_old }}
        --new-datadir={{ pg_data_dir_new }}
        --check
      register: pg_upgrade_check
      ignore_errors: yes
    - name: Fail if check fails
      fail:
        msg: "pg_upgrade check failed!"
      when: pg_upgrade_check.rc != 0
    - name: Run pg_upgrade
      command: >
        /usr/pgsql-{{ pg_new_version }}/bin/pg_upgrade
        --old-bindir=/usr/pgsql-{{ pg_old_version }}/bin
        --new-bindir=/usr/pgsql-{{ pg_new_version }}/bin
        --old-datadir={{ pg_data_dir_old }}
        --new-datadir={{ pg_data_dir_new }}
        --link
    - name: Start new cluster
      systemd:
        name: "postgresql-{{ pg_new_version }}"
        state: started
        enabled: yes

// Flyway 配置示例
@Configuration
public class FlywayConfig {
    @Bean
    public Flyway flyway(DataSource dataSource) {
        return Flyway.configure()
                .dataSource(dataSource)
                .locations("classpath:db/migration")
                .load();
    }
}