|
11.2 使用与运维
) E5 Z: B& D2 ]. P& z) m cOceanBase不是设计出来的,而是在使用过程中不断进化出来的。因此,系统使
+ O9 \6 F6 P4 M+ N用以及运维的方便性至关重要。2 Z( J* V5 t, Q
OceanBase的使用者是业务系统开发人员,并交由专门的OceanBase DBA来运; Q. B* u9 h/ R3 |3 @
维。为了方便业务使用,OceanBase实现了SQL接口且兼容MySQL协议,从而融入到* r) O# J$ G! N7 F! [
MySQL开源生态圈。MySQL大部分管理工具,例如MySQL客户端,MySQL admin,9 ?5 y% `2 F2 C; U2 o+ T
能够在OceanBase系统中直接使用。另外,OceanBase将系统运维、监控相关的内部; {3 i* Z- M6 k$ e
信息存放到内部的系统表中,从而方便运维、监控系统获取。( w# P1 p. ?& W$ X* ^
11.2.1 使用- [* ~" h/ U' p5 y) E6 l& w* E
OceanBase早期版本只允许通过Java或者C API接口访问,新版本增加了SQL支1 n9 c$ {) W1 d: I
持,且兼容MySQL客户端访问协议。OceanBase推荐用户使用SQL,但老应用仍然可
! V' |$ P' P; E8 z9 _以使用以前的Java API访问OceanBase。下面介绍几个访问与使用场景。8 O4 Y7 g1 n! _ f
1.MySQL客户端连接
# N2 x% U% f' `# k( Q5 y如图11-4所示,使用者采用MySQL客户端连接OceanBase。通过MySQL客户端可
# j: G' ~( L/ h4 M+ I以查看系统已有的表格、表格schema,执行select、update、insert、delete等SQL语0 ^: _# G" J; E3 E/ U0 B# X$ j! i
句,查看系统内部状态,以及发送OceanBase集群运维命令。图中首先通过create
& t5 e; a) }- q$ ?/ btable命令创建一张名称为test的表格,表格包含两列:id和name,其中id为主键。接( W! v# i0 K2 [. l6 L
着,往表格中写入两行记录(1,"alice"),(2,"bob")。最后,通过select语句读; T' r" _% G( v4 `
取这两行数据。0 k+ n: ?) J0 J1 |9 I
图 11-4 采用MySQL客户端连接OceanBase
2 [0 j8 J1 E5 G; Z$ q2.JDBC访问(JDBC template)2 O$ N6 V- E- x* X/ \2 }, q0 [
Java应用通过标准JDBC访问OceanBase,代码如下所示:4 P0 i2 H+ ]5 {* m3 y! z
ObGroupDataSource groupSource=new OBGroupDataSource();
& ~% s% L; T% X. R6 R9 @groupSource.setUserName("user");//设置用户名! ]8 m# K: C0 {8 Z* F
groupSource.setPasswd("pass");//设置密码
! e& r% k. _4 k h- L# D( R% _ w1 ~8 ZgroupSource.setDbName("test");//OceanBase不支持db,这里可以填任意值
7 g% z: x# X N5 o5 Z; HgroupSouorce.setConfigURL(ob_addr_url);//设置OceanBase集群的地址9 o5 O7 w5 F7 t/ l' E' \. b% A
groupSource.init();//初始化data source
6 ?7 s# n3 r" q: M5 h* EJdbcTemplate jtp=new JdbcTemplate();
$ q; e% ]2 ~( M1 \( g5 [7 hjtp.setDataSource(groupSource);//设置jdbc template依赖的data source, r4 q. X7 W1 H
String sql="select 1 from dual";
9 I% n4 G" ~" J+ \* t# J/ @" Pint ret=jtp.queryForInt(sql);//执行SQL查询
4 h; J) M% ]1 j% J3.Spring集成" A" X: P, j' T' h2 Y% J
可以通过将OceanBase DataSource集成到Spring中,配置如下:
3 Z) b2 x8 F2 d* Q. D<bean id="groupDataSource"
4 J( Y* j) c# iclass="com.alipay.oceanbase.ObGroupDataSource"1 G$ v1 V# T3 n; }" ^) q0 f
init-method="init"># K1 c6 I. L. r+ n, ~* d" X
<property name="username"value="user"/>4 @# {8 v6 R, b( P( I3 T% o
<property name="passwd"value="pass"/>, q; b) M8 [% y, V' ^& W$ c/ E
<property name="dbName"value="test"/>7 |( O' e( {8 S$ i
<property name="configURL"value=ob_addr_url/>
6 C- _& p+ N# U3 R' U</bean># d7 ~! l+ D8 g) P. @8 x1 l2 w/ l& q- G
4.C客户端# g% }8 F _! f0 A$ v
C应用通过OceanBase C客户端访问OceanBase,使用方式与MySQL C客户端完全
* T8 N. e+ P' Z' _' I0 x一致,代码如下:* R- D9 a+ e$ S1 t1 m
MYSQL mysql;4 P2 I9 s6 Z6 I. P9 A
mysql_init(&mysql); //初始化
7 X# D) l( Y3 x. S( R1 k n0 n0 ymysql_real_connect(&mysql,ob_url,ob_user,ob_pass,NULL,0,NULL,0); //连接
7 F8 I& M" B9 t: y: s6 VOceanBase数据库- i7 S/ E F4 m( S7 V' n
mysql_real_query(&mysql,sql,strlen(sql)); //执行SQL查询- Q( ~6 Y/ w& x) g' B# u
MYSQL_RES*res=mysql_store_result(&mysql); //获取SQL查询结果集
2 G' ?$ _3 t) g4 F3 u//处理SQL查询返回的结果集$ ~" @, o; j9 v: a/ q( N6 L9 h. }
while(MYSQL_ROW row=mysql_fetch_row(res)) //从结果集读取一行数据1 ?; n% m6 d0 B8 C8 W
{
8 a! V' x! s$ P* p! x4 g# c: I//处理结果集中的一行结果; t r1 G o! S. m
}
# z/ m F2 t9 }mysql_free_result(res); //释放结果集
% Y9 D+ p0 ~) `+ @4 @# z* smysql_close(&mysql); //关闭连接5 T; s/ P; D4 A
当然,应用可能会在客户端维护OceanBase连接池,Java应用还可能会使用其他
8 n( U' e! b: ~( {; s持久层框架,例如iBatis。由于OceanBase兼容JDBC和MySQL C客户端,使用MySQL3 D5 S" O( `9 M! A+ K
的应用无须修改代码就能接入OceanBase。
* V1 v2 h7 V0 k$ W4 T* `' v11.2.2 运维4 p) F6 d: X7 _0 s0 `- m' N4 h4 m
OceanBase内部实现了系统表机制,用于存储监控以及运维相关的信息。内部系
: x8 [ r! w+ L统表包含的内容如下:. r3 I. a3 S( B# L
●数据字典:表格的定义以及表格之间的关系、用户以及权限信息;
" J# ^6 o' [" O. A2 F7 N# Z5 Q' W- Q●服务器列表:集群中每种角色所在的服务器列表;
7 I4 _* ?8 |) g1 o7 G3 M: W% l●配置信息:集群中每台服务器的配置信息;
7 c" G( f$ f! U: D●内部状态:每台服务器的读写次数、读写延时、缓存命中率、子表个数、内
& T/ i- X& ^& m" M存、磁盘、CPU使用情况、请求关键路径时间消耗,每日合并状态等;
/ B5 q+ e: ?1 r3 f) O基于内部系统表,可以开发各种方便的OceanBase运维功能,如OceanBase数据, M! S7 u4 @7 M5 k+ `
库会话(Session)管理,读写性能实时监控工具、监控平台等。
' T. v4 Z, Q& ^: ]. O# \ r图11-5是OceanBase某线上应用平均读取延时的监控图,包括单行读取平均延时
! ^9 }) y4 U) P1 z9 W(average_succ_get_time)以及多行扫描平均延时(average_succ_scan_time)两个指. y. G5 S0 I# }* P% \+ P- R
标,且单位均为微秒。监控图包含三种数据:当前数据(currval),昨天数据
$ m9 _; r6 B. ?! R(lastval)以及上周数据(baseval),便于对比。由于监控、运维工具变化较快,这+ A; q7 R7 v6 B; h: c
里不做太多介绍。, D& t# \* i# v; ]6 e/ D
图 11-5 OceanBase某线上应用读取延时
% a% p" m9 S# `4 _9 F
4 a$ O2 g+ D8 O9 j7 X, s3 o$ p% d" p6 L; P9 n
; F; R! K. s" R8 u* Y/ t5 z |
|