OceanBaseSQL用户手册样本.doc
《OceanBaseSQL用户手册样本.doc》由会员分享,可在线阅读,更多相关《OceanBaseSQL用户手册样本.doc(46页珍藏版)》请在咨信网上搜索。
1、资料内容仅供您学习参考,如有不当之处,请联系改正或者删除。OceanBase SQL用户手册 本手册适用于OceanBase 0.4.1编号文档版本修订章节修订原因修订日期修订人10.1新建文档 /10/16竹翁20.2添加0.4.1版本新特性 /1/13竹翁30.3细节说明; 添加SELECT FOR UPDATE说明; 说明事务中SELECT的BUG陷阱 /1/21竹翁40.4陷阱和缺陷添加对varchar(32)的说明; 陷阱和缺陷添加REPLACE返回affected_rows的说明; 附录中添加PS语句API示例程序 /1/23竹翁50.54.1,5.1SQL语句大小写不敏感; 双引
2、号转义说明; 新增alter table语句 /3/14竹翁60.64.2增加对返回类型的描述 /3/22方戟目录1.OceanBase介绍42.快速上手4步骤一4步骤二5步骤三53.使用API63.1.C程序63.1.1.编译方法一:83.1.2.编译方法二:83.2.Java程序84.陷阱和缺陷114.1.支持的语句114.2.数据类型114.3.浮点数114.4.函数124.5.Join的限制124.6.update和delete的限制124.7.事务中SELECT的BUG124.8.REPLACE语句返回的affected_rows值125.SQL语法参考135.1.数据定义语句135
3、.1.1.create table语句135.1.2.drop table语句145.1.3.alter table语句145.2.数据操作语句155.2.1.select语句155.2.2.replace语句185.2.3.insert语句185.2.4.update语句185.2.5.delete语句185.3.事务相关语句195.3.1.开始事务195.3.2.结束事务195.4.变量相关语句195.4.1.set语句195.4.2.show variables语句205.5.预备执行语句205.5.1.prepare语句205.5.2.execute语句205.5.3.dealloca
4、te语句215.5.4.一个例子216.常见问题216.1.用replace还是insert?216.2.什么情况下需要使用预备执行语句?21附录22Prepared Statement API示例22SELECT示例22REPLACE示例251. OceanBase介绍RootServer/UpdateServer( 主) RootServer/UpdateServer( 备) Chunkserver/MergeServerOceanBase是一个由RootServer, UpdateServer, ChunkServer, MergeServer等角色组成的分布式数据库系统。RootSer
5、ver是管理服务器, 用于管理UpdateServer、 ChunkServer和MergeServer等。ChunkServer是OceanBase的基线数据存储子系统, 由多台机器构成, 基线数据一般保存23副本而且保存在不同的ChunkServer上。UpdateServer是OceanBase的增量更新子系统, 记录用户的修改, 一般由一主一备或一主多备构成。MergeServer是OceanBase的用户接口子系统, 接收用户的查询请求, 并从对应ChunkServer上获得基线数据以及从UpdateServer上获得更新的增量, 然后融合二者后返回用户。SQL用户只需要和Merge
6、Server交互, 每一个MergeServer都能够视为一个SQL服务器。用户连接任何一台MergeServer都能够对全部表格数据执行SQL语句。2. 快速上手OceanBase完全兼容MySQL的网络协议, SQL用户能够使用mysql终端客户端、 以及使用libmysqlclient的任意程序连接OceanBase。只要你熟悉mysql, 那么你就能够直接使用OceanBase SQL服务了。下面我们以mysql终端客户端为例演示一下。步骤一请询问你的OceanBase DBA任意一台MergeServer的IP地址和SQL服务端口( 默认端口号是2828) 。TODO改用LD_PRE
7、LOAD=libobsql.so启动mysql的方式步骤二使用mysql终端连接MergeServer, 如下图。注意红色部分, 如果你看到类似这样的字样, 说明你已经成功登陆了OceanBase! 像使用MySQL一样体验一下吧。步骤三我们下面能够创立一个表格, 插入一些数据, 然后查询出来。很简单, 是不是: ) 3. 使用API3.1. C程序OceanBase为应用程序提供了libobsql函数库 当前0.4.1版本没有发布libobsql, 用户暂时能够用libmysql代替。这个库在二进制接口上与mysql的libmysqlclient库完全兼容。也就是说, 一个程序( 例如mys
8、ql, mysqltest等) 之前用libmysqlclient编译好, 使用PRELOAD技术无需重新编译就能够使用来连接OceanBase。应用程序能够使用与libmysqlclient提供的API( mysql.h) 完全相同的接口直接访问OceanBase SQL服务。下面是一个简单的例子程序的完整清单。#include #include #include /是的, 你没看错, 就是mysql.hint main(int argc, char *argv) (void)argc; (void)argv; const char* HOST = 127.0.0.1; int PORT =
9、 2828; / 1. 初始化libmysqlclient if (0 != mysql_library_init(0, NULL, NULL) fprintf(stderr, could not init mysql libraryn); exit(1); MYSQL my_; ASSERT_TRUE(NULL != mysql_init(&my_); / 此处用ASSERT省略错误检查 fprintf(stderr, Connecting server %s:%d.n, HOST, PORT); / 2. 连接OceanBase SQL服务 ASSERT_TRUE(NULL != mysq
10、l_real_connect(&my_, HOST, , , test, PORT, NULL, 0); / 3. 建表 int ret = 0; ret = mysql_query(&my_, drop table if exists ob_new_sql_test); if (0 != ret) fprintf(stderr, %sn, mysql_error(&my_); ASSERT_EQ(0, ret); ret = mysql_query(&my_, create table if not exists ob_new_sql_test (c0 varchar(64), c1 int
11、 primary key, c2 int, c3 int, c4 int, c5 int, c6 int, c7 int, c8 int, c9 int, c10 int, c11 int, c12 int, c13 int, c14 int, c15 int); if (0 != ret) fprintf(stderr, %sn, mysql_error(&my_); ASSERT_EQ(0, ret); / 4. 插入数据 ret = mysql_query(&my_, insert into ob_new_sql_test (c0, c1, c2)values (hello, 1, 2)
12、; if (0 != ret) fprintf(stderr, %sn, mysql_error(&my_); ASSERT_EQ(0, ret); / 5. 查询数据 ASSERT_EQ(0, mysql_query(&my_, select * from ob_new_sql_test); MYSQL_RES *res = mysql_use_result(&my_); / 取结果集 ASSERT_TRUE(NULL != res); unsigned int num_fields = mysql_num_fields(res); / 结果列数 ASSERT_EQ(16U, num_fie
13、lds); unsigned long *lengths = NULL; MYSQL_ROW row; row = mysql_fetch_row(res); ASSERT_TRUE(NULL != row); lengths = mysql_fetch_lengths(res); / row中每个值的长度, 0表示NULL ASSERT_TRUE(NULL != lengths); for (unsigned int j = 0; j num_fields; +j) if (0 != j) fprintf(stdout, ,); fprintf(stdout, %.*s, rowj ? st
14、atic_cast(lengthsj) : static_cast(sizeof(NULL)-1), rowj ? rowj : NULL); fprintf(stdout, n); row = mysql_fetch_row(res); ASSERT_TRUE(NULL = row); / no more rows mysql_free_result(res); / 6. 删表 ret = mysql_query(&my_, drop table if exists ob_new_sql_test); if (0 != ret) fprintf(stderr, %sn, mysql_erro
15、r(&my_); / 7. destroy mysql_library_end(); return 0;恭喜你, 你已经完成了一个从OceanBase中读写数据的程序。关于API的完整说明, 请参考MySQL C API文档 见。3.1.1. 编译方法一: 首先, 需要保证你的开发机上已经安装了mysql应用开发包, 在RHEL或者fedora上能够使用如下命令安装: TODO obsql如何安装yum install mysql-devel然后, 拷贝上面的程序到一个文件ob_sql_example.cpp中, 用如下命令编译: g+ -o ob_sql_example ob_sql_exa
16、mple.cpp lmysqlclient程序编译好后, 用下面的命令运行: LD_LIBRARY_PATH= LD_PRELOAD=libobsql.so ./ob_sql_example3.1.2. 编译方法二: 你也能够在编译的时候直接使用libobsql代替libmysqlclient, 这样产生的可执行程序无需使用LD_PRELOAD的方式来执行。应用程序源码不需要任何修改, 还是包含mysql.h和使用其中的API。TODO补充libobsql执行示例的环境变量设置和头文件的g+ -o ob_sql_example ob_sql_example.cpp lobsql./ob_sql
17、_example3.2. Java程序OceanBase提供了符合Java标准的DataSource 见, OBGroupDataSource是javax.sql.DataSource的一个实现, Java应用程序能够使用OBGroupDataSource获得与OceanBase服务器交互的连接。这个库在mysql-connector-java的基础上, 实现了OceanBase多集群间流量分配, 多MergeServer间的负载均衡, 以及在单个MergeServer发生失效的情况下自动进行切换容灾等功能。下面是一个简单的例子程序的完整清单。TODO Java PS的例子package co
18、m.alipay.oceanbase;import java.io.*;import java.util.*;import java.sql.*;import javax.sql.DataSource;import com.alipay.oceanbase.OBGroupDataSource;public class ObJDBCExample public static void main(String argv) try / init the data source OBGroupDataSource ds = new OBGroupDataSource(); List instanceL
19、ist = new ArrayList(); instanceList.add(10.232.36.185:45447); / OceanBase RootServer ds.setInstanceList(instanceList); /推荐使用setConfigURL的方式, 见后 ds.setUserName(user); ds.setPasswd(password); ds.init(); / JDBC stuff Connection conn = ds.getConnection(); Statement stmt = conn.createStatement(); stmt.ex
- 配套讲稿:
如PPT文件的首页显示word图标,表示该PPT已包含配套word讲稿。双击word图标可打开word文档。
- 特殊限制:
部分文档作品中含有的国旗、国徽等图片,仅作为作品整体效果示例展示,禁止商用。设计者仅对作品中独创性部分享有著作权。
- 关 键 词:
- OceanBaseSQL 用户手册 样本
1、咨信平台为文档C2C交易模式,即用户上传的文档直接被用户下载,收益归上传人(含作者)所有;本站仅是提供信息存储空间和展示预览,仅对用户上传内容的表现方式做保护处理,对上载内容不做任何修改或编辑。所展示的作品文档包括内容和图片全部来源于网络用户和作者上传投稿,我们不确定上传用户享有完全著作权,根据《信息网络传播权保护条例》,如果侵犯了您的版权、权益或隐私,请联系我们,核实后会尽快下架及时删除,并可随时和客服了解处理情况,尊重保护知识产权我们共同努力。
2、文档的总页数、文档格式和文档大小以系统显示为准(内容中显示的页数不一定正确),网站客服只以系统显示的页数、文件格式、文档大小作为仲裁依据,平台无法对文档的真实性、完整性、权威性、准确性、专业性及其观点立场做任何保证或承诺,下载前须认真查看,确认无误后再购买,务必慎重购买;若有违法违纪将进行移交司法处理,若涉侵权平台将进行基本处罚并下架。
3、本站所有内容均由用户上传,付费前请自行鉴别,如您付费,意味着您已接受本站规则且自行承担风险,本站不进行额外附加服务,虚拟产品一经售出概不退款(未进行购买下载可退充值款),文档一经付费(服务费)、不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。
4、如你看到网页展示的文档有www.zixin.com.cn水印,是因预览和防盗链等技术需要对页面进行转换压缩成图而已,我们并不对上传的文档进行任何编辑或修改,文档下载后都不会有水印标识(原文档上传前个别存留的除外),下载后原文更清晰;试题试卷类文档,如果标题没有明确说明有答案则都视为没有答案,请知晓;PPT和DOC文档可被视为“模板”,允许上传人保留章节、目录结构的情况下删减部份的内容;PDF文档不管是原文档转换或图片扫描而得,本站不作要求视为允许,下载前自行私信或留言给上传者【丰****】。
5、本文档所展示的图片、画像、字体、音乐的版权可能需版权方额外授权,请谨慎使用;网站提供的党政主题相关内容(国旗、国徽、党徽--等)目的在于配合国家政策宣传,仅限个人学习分享使用,禁止用于任何广告和商用目的。
6、文档遇到问题,请及时私信或留言给本站上传会员【丰****】,需本站解决可联系【 微信客服】、【 QQ客服】,若有其他问题请点击或扫码反馈【 服务填表】;文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“【 版权申诉】”(推荐),意见反馈和侵权处理邮箱:1219186828@qq.com;也可以拔打客服电话:4008-655-100;投诉/维权电话:4009-655-100。