文档章节

go连接hive

zhangzhihai
 zhangzhihai
发布于 2017/09/07 12:55
字数 143
阅读 71
收藏 0

经过两天多的资料查找,反复测试从网上找到的多种方案,加上阿里云售后的支持,终于搞定Go语言连接Apache Hive的问题。 
测试环境,阿里云E-MapReduce 2.1 中的Hive, Golang 1.7,开发环境win10。 
在阿里云hive-site.xml中需要添加:

<property>
    <name>hive.server2.authentication</name>
    <value>NOSASL</value>
  </property>

代码如下:

package main

import (
    "fmt"

    "github.com/dazheng/gohive"
)

func main() {
    conn, err := gohive.Connect("127.0.0.1:10000", gohive.DefaultOptions)
    if err != nil {
        fmt.Errorf("Connect error %v", err)
    }
    defer conn.Close()

    _, err = conn.Exec("create table if not exists t(c1 int)")
    if err != nil {
        fmt.Errorf("Connection.Exec error: %v", err)
    }
}

http://blog.csdn.net/dazheng/article/details/53043946

本文转载自:http://blog.csdn.net/dazheng/article/details/53043946

共有 人打赏支持
zhangzhihai
粉丝 2
博文 18
码字总数 2207
作品 0
浦东
高级程序员
DbVisualizer 使用Impala驱动连接Hive数据库

在最近工作中使用到Hive数据库存储大数据,但是CDH环境没有提供好的管理Hive数据的界面,因此考虑到使用客户端工具连接Hive数据库进行数据查询。 连接Hive数据库的GUI客户端工具有DBeaver和D...

杨延庆
06/19
0
0
Hive中的所有Join

内连接:inner join --join优化:在进行join的时候,大表放在最后面 --但是使用 /+streamtable(大表名称)/ 来标记大表,那么大表放在什么位置都行了 select /+streamtable(s)/ s.ymd,d.divid...

qhaiyan
2016/12/03
3
0
hive(04)、使用dbeaver客户端连接hive数据仓库

我们登陆hive shell 写复杂的长的sql语句不是很方便,没有格式化拷贝粘贴等常用操作,查询结果也不是很直观,时我们可以使用第三方的客户端连接hive进行操作,于是我们使用支持hive的数据库客...

MaxBill
01/15
0
4
Hive 使用陷阱(Lock table) 排查过程

前言 业务部门使用python通过hive thrift api做数据统计,早段时间发现在频繁创建表的时候,接口会卡死。经过一番的排查,是因为hive的lock table manager特性对于hive server的接口服务不兼...

kisops
2013/08/11
0
6
Hive 使用陷阱(Lock table) 排查过程

前言 业务部门使用python通过hive thrift api做数据统计,早段时间发现在频繁创建表的时候,接口会卡死。经过一番的排查,是因为hive的lock table manager特性对于hive server的接口服务不兼...

snakelxc
2013/08/11
0
1

没有更多内容

加载失败,请刷新页面

加载更多

负载均衡的解决方案有哪些

负载均衡器服务可满足大型组织的需求,支持所有数据中心和跨数据中心高可靠性场景。 本地负载均衡,通过附带或者未附带持久性覆盖选项,Incapsula支持各种负载均衡算法,以优化服务器之间的流...

上树的熊
11分钟前
0
0
Java实现在线打开word文档加盖印章/盖章/签名功能

前言: 我们知道,大型一点的OA办公系统都会有很多在线处理office办公文档的需求。其中有一点也基本绕不开,那就是为文档盖章或添加手写签名来保护文档,让被盖章的文档不再被编辑。 在Java中...

山里的红杏
19分钟前
3
0
js控制输入正负数,小数点后保留两位

//限制数字function clearNoNum(obj){ //修复第一个字符是小数点 的情况. if(obj.value !=''&& obj.value.substr(0,1) == '.'){ obj.value=""; } obj.value ...

一直在成长的程序猿
21分钟前
1
0
动态代理

具体场景 为了使代理类与被代理类对第三方有相同的函数,代理类与被代理类一般实现一个公共的interface,定义如下 public interface Subject { void rent(); void hello(String s)...

wuyiyi
25分钟前
0
0
时间字段

我们看看这几个数据库中(mysql、oracle和sqlserver)如何表示时间 mysql数据库:它们分别是 date、datetime、time、timestamp和year。date :“yyyy-mm-dd”格式表示的日期值 time :“hh:...

DemonsI
27分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部