皮皮网

1.mysqlinsert占位符使用
2.mysqlinsertinto...select语句为什么会造成死锁?
3.MySQL全文索引源码剖析之Insert语句执行过程
4.MySql主键自增长。在插入语句时必须指定ID，否则就出错， 以下是源码，请各位高手给看看是哪里错了。
5.C#如何连接其他数据库,mysql源码开发群如MYSQL或者Postgresql
6.Flink mysql-cdc connector 源码解析

mysqlinsert占位符使用

       æ ¹æ®æŸ¥è¯¢ï¼Œmysqlinsert占位符使用参数替换方式插入，插入方式中，sql使用占位符？，然后插入值通过参数传入即可。占位符：只有主键字段才有占位符的概念 ，其表示为0，default ，null。用于替代手写insert语句 生成后自行编辑所需要的字段即可 -- python版占位符。

mysqlinsertinto...select语句为什么会造成死锁?

       在实际开发中，我遇到过MySQL死锁问题，深入研究了MySQL的锁机制以及产生死锁的场景。

       具体分析，如发现不正确之处，请指正！

       确实，数据表中若无记录，同时并发插入两条统一条记录（包含唯一键相同）可能导致死锁。

       设想三个session并发插入同一条记录（假设t1为唯一键）：

       插入操作会加排它锁。假设session 1获取排它锁，session 2和session 3则会报主键重复错误，此时行加共享锁。若有多个session尝试插入同一行，node源码交易且另一session已持有排它锁，session 2和session 3均会尝试获得共享锁。若session 1回滚，释放排它锁，session 2和session 3则可获得共享锁，此时两session死锁，均持有共享锁，欲获得排它锁。

       实际测试证实此现象。但疑惑的是，若session 1 commit，为何不会导致死锁，这原因尚不明了，期待高手解答。

       MySQL锁机制复杂，看似简单的SQL操作有时会引发死锁，初次遇到时会感到困惑。

       我曾总结过MySQL锁机制及常见死锁场景，flash socket源码分享了一个ppt，详情参见：技术分享-MySQL InnoDB locks and deadlocks。

       以下提供一些有价值的

参考资料：

       （1）MySQL官方文档，详细介绍了InnoDB锁机制： MySQL :: MySQL 5.5 Reference Manual :: .8.3 Locks Set by Different SQL Statements in InnoDB。

       （2）阿里巴巴DBA专家何登成的博客，提供了深入解析：何登成的技术博客。

       （3）《高性能MySQL》一书，对MySQL锁机制有详细讲解。

MySQL全文索引源码剖析之Insert语句执行过程

       本文来源于华为云社区，作者为GaussDB数据库，探讨了MySQL全文索引源码中Insert语句的执行过程。

       全文索引是一种常用于信息检索的技术，它通过倒排索引实现，即单词和文档的映射关系，如(单词，(文档，偏移))。以创建一个表并在opening_line列上建立全文索引为例，c set源码插入'Call me Ishmael.'时，文档会被分为'call', 'me', 'ishmael'等单词，并记录在全文索引中。

       全文索引Cache的作用类似于Change Buffer，用于缓存分词结果，避免频繁刷盘。Innodb使用fts_cache_t结构来管理cache，每个全文索引的表都会在内存中创建一个fts_cache_t对象。

       Insert语句的执行分为三个阶段：写入行记录阶段、事务提交阶段和刷脏阶段。写入行记录阶段生成doc_id并写入Innodb的行记录，并将doc_id缓存。事务提交阶段对文档进行分词，获取{ 单词，(文档，偏移)}关联对，并插入到cache。刷脏阶段后台线程将cache刷新到磁盘。病历 系统 源码

       全文索引的并发插入可能导致OOM问题，可通过修复patch #解决。当MySQL进程崩溃时，fts_init_index函数会恢复crash前的cache数据。

MySql主键自增长。在插入语句时必须指定ID，否则就出错， 以下是源码，请各位高手给看看是哪里错了。

       如果指定列插入应该不会有问题

       insert into new_mobile(mobile_name,phone_name,`date`)values('','','--');

       如果不指定列的话，自增键插入NULL

       insert into new_mobile values(null,'','','--');

       或

       insert into new_mobile(id,mobile_name,phone_name,`date`)values(null,'','','--');

       不要给id这一列插入具体的数值，否则自增无效

       另外你的表结构里date这一列以后最好不要叫这个列名，因为date本身是sql关键字，有些程序员在写sql语句的时候，不喜欢在列名两边加上``，这时候sql语句就要报错了，所以为了避免这样的麻烦，不要用sql关键字做列名

C#如何连接其他数据库,如MYSQL或者Postgresql

       using System;

       using System.Data.SqlClient;

       using System.Data;

       public class DB

       {

       static string Sql="server=.;uid=名字;pwd=密码;database=你要连的数据库";

       private SqlConnection objSqlConnection = new SqlConnection(Sql);

       //以上是加载驱动你要连到的数据库

       public int Update(string sql)

       {

       objSqlConnection.Open();

       SqlCommand objSqlCommand = new SqlCommand(sql,objSqlConnection);

       int r=objSqlCommand.ExecuteNonQuery();

       objSqlConnection.Close();

       return r; //r如果是=1就是增删改成功！

       }

       //上面的方法是增删改

       public DataSet Select(string sql)

       {

       DataSet objDataSet = new DataSet();

       SqlDataAdapter objSqlDataAdapter = new SqlDataAdapter(sql,objSqlConnection);

       objSqlDataAdapter.Fill(objDataSet);

       return objDataSet;

       }

       //这个方法是查；

       }

       这是一个连接SQL的类；

       你建这样的一个类，在哪个地方要就实例后调他的方法带入一个参数；

       参数是SQL增删改查的语句；

       如果要在你做的那个程序实现增删改的话就

       DB db = new DB();

       int i = DB.Update(增的SQL语句);

       // 返回的i是1就是成功了！

       ===========================

       DB db = new DB();

       int i = DB.Update(删的SQL语句);

       // 返回的i是1就是成功了！

       ==========================

       DB db = new DB();

       int i = DB.Update(改的SQL语句);

       // 返回的i是1就是成功了！

       ========================如果要查询

       DB db = new DB();

       DataSet ds = new DataSet();

       ds = db.Select(查的SQL语句);

       //查询出的结果就放在ds里面；

Flink mysql-cdc connector 源码解析

       Flink 1. 引入了 CDC功能，用于实时同步数据库变更。Flink CDC Connectors 提供了一组源连接器，支持从MySQL和PostgreSQL直接获取增量数据，如Debezium引擎通过日志抽取实现。以下是Flink CDC源码解析的关键部分：

       首先，MySQLTableSourceFactory是实现的核心，它通过DynamicTableSourceFactory接口构建MySQLTableSource对象，获取数据库和表的信息。MySQLTableSource的getScanRuntimeProvider方法负责创建用于读取数据的运行实例，包括DeserializationSchema转换源记录为Flink的RowData类型，并处理update操作时的前后数据。

       DebeziumSourceFunction是底层实现，继承了RichSourceFunction和checkpoint接口，确保了Exactly Once语义。open方法初始化单线程线程池以进行单线程读取，run方法中配置DebeziumEngine并监控任务状态。值得注意的是，目前只关注insert, update, delete操作，表结构变更暂不被捕捉。

       为了深入了解Flink SQL如何处理列转行、与HiveCatalog的结合、JSON数据解析、DDL属性动态修改以及WindowAssigner源码，可以查阅文章。你的支持是我写作的动力，如果文章对你有帮助，请给予点赞和关注。

       本文由文章同步助手协助完成。

MySql轻松入门系列——第二站 使用visual studio 对mysql进行源码级调试

       在探索MySQL世界的过程中，有些同学希望更深入地了解如何在Visual Studio中进行源码级调试。不用担心，让我们一步步来。

       必备工具

       MySQL是用C++编写的，要在Windows上编译，需要几个关键工具：CMake用于生成可打开的解决方案，如MySQL.sln；Boost是强大的C++库，Bison是用于解析MySQL语法规则的工具；当然，选择适合自己版本的MySQL源码（如5.7.）也是必不可少的。

       详细安装步骤

       安装过程需要细心，特别是Bison，务必避免默认路径中的空格问题，以免后续VS编译受阻。安装CMake和Bison时选择自定义路径，例如C:\2\GnuWin，确保它们的bin文件路径被添加到环境变量中。接下来解压mysql-5.7..zip，构建项目。

       编译与调试

       使用CMake编译MySQL源码，当看到Build files written to: C:/2/mysql-5.7./brelease，说明成功生成.sln文件。用Visual Studio 打开MySql.Sln，耐心等待十几分钟，编译成功后即可进行下一步。

       启动MySQL并调试

       首先，开启MySQL的调试模式，修改mysqld.cc中的test_lc_time_sz方法。然后，在Visual Studio的命令行参数中加入--console --initialize，开始调试。可能会遇到编码问题，解决后，输入默认密码zJDE>IC5o+ya，连接到MySQL并修改密码。

       追踪write_row

       在上一篇中提到的write_row是一个虚方法，通过实际调试，我们可以看到它在ha_innodb.cc的实现。设置断点，执行insert操作，可以看到代码进入ha_innodb::write_row方法，深入查看局部变量和调用堆栈，验证之前的理论。

       总结

       通过一整天的努力，我们掌握了在Visual Studio中对MySQL源码进行调试的技巧。记住，每一步都可能是个挑战，但只有亲自动手，才能真正理解MySQL的运作机制。希望这些经验能帮助你避免一些常见的坑，祝你在源码的世界里探索得更深入！