1.Flink深入浅出：JDBC Connector源码分析
2.如何创建SQL表？
3.MySQL-一- 创建数据表
4.在mysql中怎样显示表里的链接内容

Flink深入浅出：JDBC Connector源码分析

       大数据开发中，数据分析与报表制作是表属表源l表日常工作中最常遇到的任务。通常，于s源码我们通过读取Hive数据来进行计算，码链并将结果保存到数据库中，接表然后通过前端读取数据库来进行报表展示。属于c 窗口 源码然而，链接使用FlinkSQL可以简化这一过程，表属表源l表通过一个SQL语句即可完成整个ETL流程。于s源码

       在Flink中，码链读取Hive数据并将数据写入数据库是接表常见的需求。本文将重点讲解数据如何写入数据库的属于过程，包括刷写数据库的链接机制和原理。

       以下是表属表源l表本文将讲解的几个部分，以解答在使用过程中可能产生的于s源码疑问：

       1. 表的定义

       2. 定义的表如何找到具体的实现类（如何自定义第三方sink）

       3. 写入数据的机制原理

       （本篇基于1..0源码整理而成）

       1. 表的定义

       Flink官网提供了SQL中定义表的示例，以下以oracle为例：

       定义好这样的表后，就可以使用insert into student执行插入操作了。接下来，csdn源码怎么用我们将探讨其中的技术细节。

       2. 如何找到实现类

       实际上，这一过程涉及到之前分享过的SPI（服务提供者接口），即DriverManager去寻找Driver的过程。在Flink SQL执行时，会通过translate方法将SQL语句转换为对应的Operation，例如insert into xxx中的xxx会转换为CatalogSinkModifyOperation。这个操作会获取表的信息，从而得到Table对象。如果这个Table对象是CatalogTable，则会进入TableFactoryService.find()方法找到对应的实现类。

       寻找实现类的过程就是SPI的过程。即通过查找路径下所有TableFactory.class的实现类，加载到内存中。这个SPI的定义位于resources下面的META-INFO下，定义接口以及实现类。

       加载到内存后，KK开源源码首先判断是否是TableFactory的实现类，然后检查必要的参数是否满足（如果不满足会抛出异常，很多人在第一次使用Flink SQL注册表时，都会遇到NoMatchingTableFactoryException异常，其实都是因为配置的属性不全或者Jar报不满足找不到对应的TableFactory实现类造成的）。

       找到对应的实现类后，调用对应的createTableSink方法就能创建具体的实现类了。

       3. 工厂模式+创建者模式，创建TableSink

       JDBCTableSourceSinkFactory是JDBC表的具体实现工厂，它实现了stream的sinkfactory。在1..0版本中，它不能在batch模式下使用，但在1.版本中据说会支持。这个类使用了经典的工厂模式，其中createStreamTableSink负责创建真正的Table，基于创建者模式构建JDBCUpsertTableSink。

       创建出TableSink之后，量化策略源码出售就可以使用Flink API，基于DataStream创建一个Sink，并配置对应的并行度。

       4. 消费数据写入数据库

       在消费数据的过程中，底层基于PreparedStatement进行批量提交。需要注意的是提交的时机和机制。

       控制刷写触发的最大数量 'connector.write.flush.max-rows' = ''

       控制定时刷写的时间 'connector.write.flush.interval' = '2s'

       这两个条件先到先触发，这两个参数都是可以通过with()属性配置的。

       JDBCUpsertFunction很简单，主要的工作是包装对应的Format，执行它的open和invoke方法。其中open负责开启连接，invoke方法负责消费每条数据提交。

       接下来，我们来看看关键的format.open()方法：

       接下来就是消费数据，执行提交了

       AppendWriter很简单，只是javaweb简单增删源码对PreparedStatement的封装而已

       5. 总结

       通过研究代码，我们应该了解了以下关键问题：

       1. JDBC Sink执行的机制，比如依赖哪些包？（flink-jdbc.jar，这个包提供了JDBCTableSinkFactory的实现）

       2. 如何找到对应的实现？基于SPI服务发现，扫描接口实现类，通过属性过滤，最终确定对应的实现类。

       3. 底层如何提交记录？目前只支持append模式，底层基于PreparedStatement的addbatch+executeBatch批量提交

       4. 数据写入数据库的时机和机制？一方面定时任务定时刷新，另一方面数量超过限制也会触发刷新。

       更多Flink内容参考：

如何创建SQL表？

       åˆ›å»ºæ•°æ®åº“表首先得创建好数据库，数据库的具体创建方法请参见：/article/feab3d.html

       2

       æ•°æ®åº“创建好之后，如图点开数据库，鼠标选中表，右键选择【新建表】。

       3

       åœ¨å¼¹å‡ºçš„表的新建窗口中填入相关表信息。这里创建的是学生信息相关的表，包含信息如图。

       4

       è¡¨ä¿¡æ¯å¡«å†™å¥½ä¹‹åŽï¼Œå¦‚果有需要就可以设置主键（主键：表中经常有一个列或多列的组合，其值能唯一地标识表中的每一行。）。设置方法为，选中要设置的列右键设置为主键即可。

       5

       è¡¨ä¿¡æ¯å¡«å†™å®Œæ¯•ï¼Œä¹Ÿè®¾ç½®äº†ç›¸åº”的键，下面就是保存表，可以【ctrl+s】，在弹出的框内填写表名，然后确定。也可以直接点击创建表窗口右上角的关闭按钮，在弹出的框内填写表名，然后确定。表创建完成。

       END

       SQL命令创建数据表

       ç‚¹å‡»ã€æ–°å»ºæŸ¥è¯¢ã€‘按钮，打开SQL命令编辑框，对数据库表的操作以及维护都可以通过编辑SQL命令实现。

       åœ¨ç¼–辑框内编辑创建数据库表的代码，确认代码无误后，单击【执行】按钮，创建数据表。

       3

       åˆ›å»ºæ•°æ®è¡¨çš„源代码如下，各命令详见请自行百度。

       use test

       go

       if exists(select name from sys.tables where name='Student')

       drop table Student

       go

       create table Student

       (sname nchar() primary key,

       sex nchar(2) not null,

       bir datetime

       )

MySQL-一- 创建数据表

       问题一：如何验证MySQL数据库安装成功？

       问题二：如何用客户端navicat连接到MySQL数据库？

       练习：创建学校数据库的表

       2.创建数据库

       2.1 创建学生表student

       2.2创建成绩表score

       2.3创建课程表course

       2.4创建教师表 teacher

       3.练习插入数据

       3.1 向学生表里添加数据

       3.2向成绩表中添加数据

       3.3向课程表中添加数据

       3.4向教师表中添加数据

       本关总结：

       1.理解MySQL和Neviacat Premium,什么是MySQL? 什么是Nevicat？

       MySQL是一个开放源码的关系数据库管理系统。MySQL是使用比较广泛的一种关系型数据库。

       1.1 什么是数据库？什么是关系型数据库？

       数据库可以将它看成是存储数据的仓库。

       关系型数据库是一种建立在关系模型（数据模型）上的数据库。一个关系型数据库就是由二维表及其之间的关系组成的一个数据组织。

       1.2 什么是Neviacat？

       Navicat Premium是一套数据库管理工具，它只是mysql的一个管理工具，不用它还有很多选择。

       2.SQL（Structured Query Language，结构化查询语言)

       2.1什么是结构化数据，结构化查询语言？

       结构化数据就是经过整理后有秩序的数据，你可以通过某种规则去获取。SQL是一种特殊目的的编程语言，是一种数据库查询和程序设计语言，用于存取数据以及查询、更新和管理关系数据库系统，SQL是关系型数据库的操作指令，是一种约束，但是不强制。

       2.2 SQL又分为四（五）部分：

       DDL （Data Definition Language）数据定义语言：用在定义或改变表（TABLE）的结构，数据类型，表之间的链接和约束等初始化工作上，他们大多在建立表时使用。（改变数据库结构，包括创建、更改和删除数据库对象，不需要commit)。

       DML （Data Manipulation Language）数据操纵语言：DML是用来对数据库里的数据进行操作的语言。数据操纵语言用于检索、插入和修改数据。需要commit

       数据操纵语言命令包括：

       DCL （Data Control Language）数据控制语言，用于数据库授权、角色控制等操作。它主要负责权限管理，它可以把语句权限或者 对象权限授予给其他用户和角色。如：grant（分配权限），DENY 拒绝授权，revoke（撤销授权）等

       TCL（Transaction Control Language 事务控制语言）

       3.关系键是什么？主键是什么？

       关系键是 关系数据库的重要组成部分。关系键是一个表中的一个或几个属性，用来标识该表的每一行或与另一个表产生联系

       3.1主键（primary key）， 数据库表中对储存数据对象予以唯一和完整标识的 数据列或属性的组合。一个数据表只能有一个主键，且主键的取值不能缺失，即不能为 空值（Null）；例如找学生的学号而不是名字才能找出唯一的一个人。

       数据库表，又称表格，是一系列二维数组的集合，用来代表和储存数据对象之间的

       4.安装使用过程中一些小问题：

       3.1 MySQL 数据库输入密码后闪退

       需要手动开启SQL服务，我的电脑-管理-服务和应用程序-服务-启动-重新启动并测试。解决！

       3.2 Navicat中的连接显示灰色表示没打开，双击即可。

       3.3 编辑时，要求英文逗号，语句结尾要加分号。

       3.3 Navicat查询编辑器运行完代码后要保存，回到表中最好点一下刷新按钮。

在mysql中怎样显示表里的内容

       select * from 表名称 即可。

       如果是要查询某一个表某一个列的在这个表中的详细信息，可以用

       select * from 表名称 where 列名称=筛选条件  如学号，姓名等，中文字段或特殊字段需加‘’（‘小明’）等。

扩展资料：

       MySQL是一个关系型数据库管理系统，由瑞典MySQL AB 公司开发，目前属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一，在 WEB 应用方面，MySQL是最好的 RDBMS (关系数据库管理系统) 应用软件。

       MySQL是一种关系数据库管理系统，关系数据库将数据保存在不同的表中，而不是将所有数据放在一个大仓库内，这样就增加了速度并提高了灵活性。

       MySQL所使用的 SQL 语言是用于访问数据库的最常用标准化语言。MySQL 软件采用了双授权政策，分为社区版和商业版，由于其体积小、速度快、总体拥有成本低，尤其是开放源码这一特点，一般中小型网站的开发都选择 MySQL 作为网站数据库。

       由于其社区版的性能卓越，搭配 PHP 和 Apache 可组成良好的开发环境。

       参考资料：

百度百科——mysql