首页 > 数据库技术 > 详细

大数据之数据库获取数据

时间:2020-07-10 01:29:01      阅读:82      评论:0      收藏:0      [点我收藏+]

package com.sjw.flink

import org.apache.flink.api.common.typeinfo.BasicTypeInfo
import org.apache.flink.api.java.io.jdbc.JDBCInputFormat
import org.apache.flink.api.java.typeutils.RowTypeInfo
import org.apache.flink.api.scala._
import org.apache.flink.types.Row

object JDBCSourceTest {

def main(args: Array[String]): Unit = {

// //搭建环境
// val env = ExecutionEnvironment.getExecutionEnvironment
// var inputMysq: DataSet[Row] = MyJDBCRead(env)
// inputMysq.map(r => (r.getField(0),r.getField(1))).print()
//
// def MyJDBCRead(env:ExecutionEnvironment): DataSet[Row] ={
//
// var inputMysql: DataSet[Row] = env.createInput(JDBCInputFormat.buildJDBCInputFormat()
// .setDrivername("com.mysql.jdbc.Driver")
// .setDBUrl("jdbc:mysql://sunjunwei1.com:3306/1711F")
// .setUsername("root")
// .setPassword("986262")
// .setQuery("select sensor,temp from temperature")
// .setRowTypeInfo(new RowTypeInfo(BasicTypeInfo.STRING_TYPE_INFO,BasicTypeInfo.DOUBLE_TYPE_INFO))
// .finish()
// )
// inputMysql
// }

}

}

大数据之数据库获取数据

原文:https://www.cnblogs.com/whyuan/p/13276955.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!