数据库：分布式

heidsoft

发布于 2023-03-18 17:23:29

46200

代码可运行

文章被收录于专栏：云计算与大数据云计算与大数据

运行总次数：0

代码可运行

数据库：分布式

分布式数据库分为同构或异构两类
分布式数据库存储数据的问题
分布式数据库系统中的事物处理模型
分布式数据库如何通过使用特殊的提交协议来实现分布式数据库中的原子事物
分布式数据的并发控制
分布式数据库如何通过复制来提供分布式数据库中的高可用性，使得即使出现故障，系统仍然可以继续处理事物

分布式数据存储

复制（replication）: 系统维护这个关系的几个相同的副本（拷贝），并把每个副本存储在不同的站点上。复制的替代方式是只存储关系的一份拷贝。

分片（fragmentation）: 系统把关系划分为几个片，并把每个片存储在不同的站点上。

分片和复制可以组合，一个关系可以划分为几个片，并且每个片可以有几个副本。

sql/rpl_handler.cc

/**
   Transaction observer parameter initialization.
*/
#define TRANS_PARAM_ZERO(trans_param_obj) \
  memset(&trans_param_obj, 0, sizeof(Trans_param));

// 事务代表-事务开启函数
int Trans_delegate::trans_begin(THD *thd, int &out) {
  DBUG_TRACE;
  Trans_param param;
  // 事务参数初始化
  TRANS_PARAM_ZERO(param);
  param.server_uuid = server_uuid;
  param.thread_id = thd->thread_id();
  param.group_replication_consistency =
      thd->variables.group_replication_consistency;
  param.hold_timeout = thd->variables.net_wait_timeout;
  param.server_id = thd->server_id;
  param.rpl_channel_type = thd->rpl_thd_ctx.get_rpl_channel_type();

  int ret = 0;
  FOREACH_OBSERVER_ERROR_OUT(ret, begin, &param, out);
  return ret;
}

/** Transaction states (trx_t::state) */
enum trx_state_t {

  TRX_STATE_NOT_STARTED,

  /** Same as not started but with additional semantics that it
  was rolled back asynchronously the last time it was active. */
  TRX_STATE_FORCED_ROLLBACK,

  TRX_STATE_ACTIVE,

  /** Support for 2PC/XA */
  TRX_STATE_PREPARED,

  TRX_STATE_COMMITTED_IN_MEMORY
};

本文参与腾讯云自媒体同步曝光计划，分享自微信公众号。

原始发表：2023-01-28，如有侵权请联系 cloudcommunity@tencent.com 删除

数据库