• ADADADADAD

    MySQL连接查询流程源码[ mysql数据库 ]

    mysql数据库 时间:2024-12-03 12:13:33

    作者:文/会员上传

    简介:

    来源: 互联网
    版本: 不详, 仅做参考用

    初始化:
    点击(此处)折叠或打开main
    |-mysqld
    |-my_init // 初始话线程变量,互斥量
    |-load_defaults // 获取配置
    |-init_common_varia

    以下为本文的正文内容,内容仅供参考!本站为公益性网站,复制本文以及下载DOC文档全部免费。

    来源: 互联网
    版本: 不详, 仅做参考用

    初始化:

    点击(此处)折叠或打开

      main
      |-mysqld
      |-my_init // 初始话线程变量,互斥量
      |-load_defaults // 获取配置
      |-init_common_variables // 初始化变量
      |-init_server_components// 初始化插件
      | |-plugin_init
      | | |-plugin_initialize
      | |-initialize_storage_engine
      |-network_init// 监听网络
      |-grant_init
      |-servers_init
      |-udf_init

    插件启动:

    点击(此处)折叠或打开

      main
      |-mysqld_main
      |-init_server_components
      |-plugin_init
      |-plugin_initialize
      |-ha_initialize_handlerton
      |-innobase_init

    登录过程:

    点击(此处)折叠或打开

      main
      |-mysqld_main
      |-network_init// 建立socket监听,一个针对网络,一个针对unix域
      |-handle_connections_sockets
      |-poll
      |-mysql_socket_accept // 和客户端建立连接
      |-create_new_thread // 针对每个socket连接建立一个新的线程
      |-create_thread_to_handle_connection
      |-waiting_thd_list->push_back(thd);mysql_cond_signal(&COND_thread_cache); // 已有连接处理线程时,通过信号唤醒,处理线程函数为pfs_spawn_thread
      |-mysql_thread_create(启动的线程执行函数,inline_mysql_thread_create)
      |-spawn_thread_v1
      |-pthread_create(pfs_spawn_thread)

    处理连接:


    点击(此处)折叠或打开

      pfs_spawn_thread
      |-handle_one_connection
      |-do_handle_one_connection
      |-MYSQL_CALLBACK_ELSE(thread_scheduler, init_new_connection_thread, (), 0)
      | |-init_new_connection_handler_thread
      |-thd_prepare_connection
      | |-login_connection// 判断是否可以login,不可以则断开连接返回错误
      | | |-check_connection
      | | | |-acl_authenticate
      | | | |-do_auth_once
      | | | |-native_password_authenticate
      | | | |-server_mpvio_write_packet
      | | | | |-send_server_handshake_packet// 发送handshake包到客户端
      | | | | |-my_net_write
      | | | | | |-net_write_buff // 将数据写入到内存
      | | | | |-net_flush // 将内存中数据发送到网络
      | | | |-server_mpvio_read_packet// 从客户端接收Login Request信息
      | | | |-my_net_read
      | | |-Protocol::end_statement
      | | |-Protocol::send_ok
      | | |-net_send_ok // 发送response ok
      | | |-my_net_write
      | |-prepare_new_connection_state
      |-do_command
      |-dispatch_command
      |-mysql_parse

    select命令:


    点击(此处)折叠或打开

      pfs_swpawn_thread
      |-handle_one_connection
      |-do_handle_one_connection
      |-do_command
      |-dispatch_command
      |-mysql_parse
      |-parse_sql
      | |-MYSQLparse
      |-mysql_execute_command
      |-select_precheck
      | |-check_table_access
      |-execute_sqlcom_select
      | |-open_normal_and_derived_tables
      | |-open_tables
      | | |-open_and_process_table
      | | |-open_table(THD *thd, TABLE_LIST *table_list, Open_table_context *ot_ctx)
      | | |-Table_cache::get_table
      | | |-get_table_share_with_discover
      | | | |-get_table_share
      | | | |-open_table_def
      | | |-my_malloc // 申请表数据结构
      | | |-open_table_from_share
      | | |-handler::ha_open
      | | |-ha_innobase::open
      | | |-dict_table_open_on_name
      | | |-dict_load_table
      | | |-btr_pcur_is_on_user_rec
      | | |-dict_load_table_low
      | | | |-dict_mem_table_create
      | | |-fil_space_for_table_exists_in_mem
      | | |-fil_open_single_table_tablespace // 打开表空间文件
      | |-mysql_handle_derived
      |-handle_select
      |-mysql_select
      |-mysql_prepare_select
      | |-JOIN::prepare
      |-mysql_execute_select
      |-JOIN::exec
      |-select_send::send_result_set_metadata
      | |-Protocol::send_result_set_metadata
      |-do_select
      |-sub_select
      |-evaluate_join_record
      |-end_send
      |-select_send::send_data
      |-Protocol::write

    MySQL连接查询流程源码.docx

    将本文的Word文档下载到电脑

    推荐度:

    下载
    热门标签: mysql查询流程