Impala插入数据

数据库 waitig 826℃ 百度已收录 0评论

1、使用impala shell插入数据,基本语法如下:
插入一条新数据:

INSERT INTO table_name [(c1,c2,…,cn)] VALUES(v1,v2,…,vn);

覆盖数据表中现有数据:

INSERT OVERWRITE table_name[(c1,c2,…,cn)] VALUES(v1,v2,…,vn);

查询表中的记录,基本语法:

SELECT c1,c2 | * FROM table_name;

向my_db库中的student表中插入一条记录:

INSERT INTO my_db.student(name,age,contace) VALUES('lll',18,111111);

验证插入记录:

SELECT * FROM my_db.student;

执行结果如下图:
这里写图片描述
2、使用python进行操作, 代码如下:

# coding:utf-8
from impala.dbapi import connect

# 连接impala
conn = connect(host='192.168.83.144',port=21050)
cur = conn.cursor()

# 执行命令
insert_sql = ''' INSERT INTO my_dbbypy.student(name,age,contace) VALUES('sss',19,222222) '''
cur.execute(insert_sql)
print "Inserted"

cur.execute('use my_dbbypy')
cur.execute('SELECT * FROM student')
for value in cur.fetchall():
    print value

# 关闭连接
cur.close()
conn.close()

执行程序,结果如下:

Inserted
('sss', 19, 222222)

本文由【waitig】发表在等英博客
本文固定链接:Impala插入数据
欢迎关注本站官方公众号,每日都有干货分享!
等英博客官方公众号
点赞 (0)分享 (0)