datasource(dataSource理解)

编程之家2024-02-05104次浏览

一、sqldatasource是什么意思

这是连接数据库的字符串，Data Source是数据源，Initial Catalog是数据库的名称，User ID是登录数据的用户名，Pwd是登录数据库的密码。

"Data Source=.;Initial Catalog=MyQQ;User ID=sa;Pwd=sa"，这串代码DataSource等号后面的那个点是代表你所使用的数据库是本地数据库，本地数据库默认的实例名就是.\SQLEXPRESS。

特别注意的是：正常用一个点就可以代表本地数据库了，但是如果你在运行的时候还是跳出错误的话，可以将一个点改成".\SQLEXPRESS"，这样就没有问题了。

扩展资料

数据库的常见操作语句：

1、创建数据库

Createdatabase Test

2、删除数据库

Drop database Test

3、备份数据库

backup database Test to disk='E:/Test.bak'

4、还原数据库

restore database Test from disk='E:/Test.bak'

参考资料：百度百科-SQL数据库连接

二、Flink--对DataSource的理解

1、fromCollection(Collection)-从 Java的 Java.util.Collection创建数据流。集合中的所有元素类型必须相同。

2、fromCollection(Iterator, Class)-从一个迭代器中创建数据流。Class指定了该迭代器返回元素的类型。

3、fromElements(T…)-从给定的对象序列中创建数据流。所有对象类型必须相同。

4、fromParallelCollection(SplittableIterator, Class)-从一个迭代器中创建并行数据流。Class指定了该迭代器返回元素的类型。

5、generateSequence(from, to)-创建一个生成指定区间范围内的数字序列的并行数据流。

1、readTextFile(path)-读取文本文件，即符合 TextInputFormat规范的文件，并将其作为字符串返回。

2、readFile(fileInputFormat, path)-根据指定的文件输入格式读取文件（一次）。

3、readFile(fileInputFormat, path, watchType, interval, pathFilter, typeInfo)-这是上面两个方法内部调用的方法。它根据给定的 fileInputFormat和读取路径读取文件。根据提供的 watchType，这个 source可以定期（每隔 interval毫秒）监测给定路径的新数据（FileProcessingMode.PROCESS_CONTINUOUSLY），或者处理一次路径对应文件的数据并退出（FileProcessingMode.PROCESS_ONCE）。你可以通过 pathFilter进一步排除掉需要处理的文件。

实现:

重要注意：

socketTextStream(String hostname, int port)-从 socket读取。元素可以用分隔符切分。

addSource-添加一个新的 source function。例如，你可以 addSource(new FlinkKafkaConsumer011<>(…))以从 Apache Kafka读取数据。

1、基于集合：有界数据集，更偏向于本地测试用

2、基于文件：适合监听文件修改并读取其内容

3、基于 Socket：监听主机的 host port，从 Socket中获取数据

4、自定义 addSource：大多数的场景数据都是无界的，会源源不断的过来。比如去消费 Kafka某个 topic上的数据，这时候就需要用到这个 addSource，可能因为用的比较多的原因吧，Flink直接提供了 FlinkKafkaConsumer011等类可供你直接使用。你可以去看看 FlinkKafkaConsumerBase这个基础类，它是 Flink Kafka消费的最根本的类。

5、flink目前支持的source详细可以阅读官网connects部分；

三、SQL数据库中DataSource是什么意思