栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

tiDB笔记

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

tiDB笔记

docker-compose安装参考地址GitHub链接

$ git clone https://github.com/pingcap/tidb-docker-compose.git
$ cd tidb-docker-compose && docker-compose pull # Get the latest Docker images
$ sudo setenforce 0 # only on Linux
$ docker-compose up -d
docker-compose ps # 查看docker-compose启动的容器

启动后可在浏览器打开以下:
grafana: localhost:3000
localhost:8010
可像连接MySQL一样连接tiDB,端口是4000

create database if not exists smap_db;
show databases;
drop database smap_db;
use smap_db;
show tables;
create table if not exists person(
	id int(11),
	name varchar(30),
	create_at date
);
show create table person;
drop table person;
show index from person; -- 查看person表索引
create index create_at_idx on person(create_at);
drop index create_at_idx on person;
create unique index name_idx on person(name);
insert into person values(1,'n1','2022-02-02');
select * from person;

create user 'user_ti'@'0.0.0.0' identified by '123456';
grant select on smap_db.* to 'user_ti'@'0.0.0.0';
show grants for 'user_ti'@'0.0.0.0';
show grants;
drop user 'user_ti'@'0.0.0.0';
select version();

select now(); -- 2022-02-02 06:52:06
update person set name='nn' where id = 1;
select * from person;
set @@tidb_snapshot='2022-02-02 06:52:06';  -- 设置后当前会话则查询的是此时间点前的历史数据
select @@tidb_snapshot;
select * from person;
set @@tidb_snapshot='';


## 将dss.ddl导入到tidb,导入后刷新会发现多了一个数据库TPCH_001
D:xxlearntiDBtidb-docker-compose>docker-compose exec tispark-master bash
bash-4.4# cd /opt/spark/data/tispark-sample-data/
bash-4.4# ls
customer.tbl  dss.ddl  lineitem.tbl  nation.tbl  orders.tbl  part.tbl  partsupp.tbl  region.tbl  sample_data.sh  supplier.tbl
bash-4.4# mysql -h tidb -P 4000 -u root < dss.ddl
bash-4.4#
# 启动spark shell查询数据
D:xxlearntiDBtidb-docker-compose>docker-compose exec tispark-master /opt/spark/bin/spark-shell
scala> import org.apache.spark.sql.TiContext
scala> val ti=new TiContext(spark)
scala> ti.tidbMapDatabase("TPCH_001")
scala> spark.sql("select count(*) from CUSTOMER").show
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/723452.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号