1
# 写入流程
2
def write_to_db(data):
3
    # 1. 写入 WAL（预写日志）
4
    wal.append(data)
5

6
    # 2. 更新内存缓冲
7
    buffer.update(data)
8

9
    # 3. 异步刷新到磁盘
10
    # 如果在这之前断电...
11

12
    return "success"  # 返回成功，但数据还在内存！

1
# WAL 的工作原理
2
def write_with_wal(data):
3
    # 1. 先写入日志（必须先落盘）
4
    wal.append(log_record)
5
    fsync(wal)  # 强制刷盘
6

7
    # 2. 然后更新内存
8
    buffer.update(data)
9

10
    # 3. 定期将内存刷新到磁盘
11
    # 如果 crash 发生，可以从 WAL 恢复

1
# fsync 确保数据写入磁盘
2
import os
3

4
# 确保文件写入磁盘
5
os.fsync(file_handle)
6

7
# 不调用 fsync，数据可能在缓存中

1
# 组提交：批量 fsync
2
def group_commit():
3
    while True:
4
        # 收集一批日志
5
        logs = batch_collect(wal, timeout=5ms)
6

7
        if logs:
8
            # 一次性刷盘
9
            for log in logs:
10
                write(log)
11
            fsync()  # 一次 fsync
12

13
            # 通知所有请求完成
14
            for log in logs:
15
                log.done()

1
# PostgreSQL 配置
2
fsync = on  # 推荐开启
3
synchronous_commit = on  # 推荐开启
4
full_page_writes = on  # 推荐开启
5

6
# MySQL (InnoDB)
7
innodb_flush_log_at_trx_commit = 1  # 每次提交都刷盘
8
innodb_flush_log_at_trx_commit = 2  # 提交时写入文件缓存
9
innodb_flush_log_at_trx_commit = 0  # 最快，但最不安全

1
# PostgreSQL 最安全配置
2
fsync = on
3
synchronous_commit = on
4
full_page_writes = on
5
wal_level = replica
6
max_wal_senders = 3
7

8
# MySQL 最安全配置
9
innodb_flush_log_at_trx_commit = 1
10
innodb_support_xa = on
11
sync_binlog = 1

1
# PostgreSQL 备份
2
pg_dump -Fc mydb > backup.dump
3

4
# MySQL 备份
5
mysqldump --single-transaction mydb > backup.sql

1
# Cassandra 的最终一致性
2
# 写入时：写入任意节点即可
3
# 配置：W + R > N 才能保证强一致性
4

5
# DynamoDB 的配置
6
Table:
7
  WriteCapacityUnits: 100
8
  BillingMode: PROVISIONED