2. 放入hive的lib目录
3. mongdb中插入一些测试数据：
db.student.insert({"name":"张三","age":"22","sex":"男","class":"计算机2班"});//如果数据库中不存在集合，就创建
db.student.insert({"name":"李四","age":"23","sex":"女","class":"计算机3班"});
db.student.insert({"name":"王五","age":"24","sex":"男","class":"计算机2班"});
db.student.insert({"name":"刘六","age":"25","sex":"男","class":"计算机3班"});
db.student.insert({"name":"赵七","age":"26","sex":"女","class":"计算机3班"});
db.student.insert({"name":"吴八","age":"28","sex":"女","class":"计算机2班"});
4. hive 中创建表
create external table student
( id string,
name string,
age string,
sex string,
class string
)
stored by ‘com.mongodb.hadoop.hive.MongoStorageHandler‘
with serdeproperties(‘mongo.columns.mapping‘=‘{"id":"_id","name":"name","age":"age","sex":"sex","class":"class"}‘)
tblproperties(‘mongo.uri‘=‘mongodb://root:e19ee8c4@192.168.0.12:40000/test_v3.student‘);
查询数据如下：
select * from student;
数据是实时同步的：
mongodb中插入一条数据如下：
db.student.insert({"name":"杨十","age":"28","sex":"男","class":"计算机3班"});
在做查询：
mongodb中修改一条数据如下：
db.student.update({"name":"张三"},{$set:{"name":"张无忌"}});#只想改某个key的value使用set
mongodb中删除一条数据如下：
db.student.remove({"name":"张无忌"});#删除
看张无忌大哥已经不在了，缅怀一下下。
