数据库–Cobar分布式数据库集群MySQL中间件

01

#创建dbtest1脚本

02

dropdatabaseif exists dbtest1;

03

createdatabasedbtest1;

04

use dbtest1;

05

#在dbtest1上创建tb1

06

createtabletb1(

07

idintnotnull,

08

gmtdatetime);

09

#创建dbtest2

10

dropdatabaseif exists dbtest2;

11

createdatabasedbtest2;

12

use dbtest2;

13

#在dbtest2上创建tb2

14

createtabletb2(

15

idintnotnull,

16

val

varchar

(256));

17

#创建dbtest3

18

dropdatabaseif exists dbtest3;

19

createdatabasedbtest3;

20

use dbtest3;

21

#在dbtest3上创建tb2

22

createtabletb2(

23

idintnotnull,

24

val

varchar

(256));

01

<!DOCTYPE cobar:schema SYSTEM "schema.dtd">

02

<

cobar:schema

xmlns:cobar

=

"http://cobar.alibaba.com/"

>

03

<!-- schema定义 -->

04

<

schema

name

=

"dbtest"

dataNode

=

"dnTest1"

>

05

<

table

name

=

"tb2"

dataNode

=

"dnTest2,dnTest3"

rule

=

"rule1"

/>

06

</

schema

>

07

<!-- 数据节点定义，数据节点由数据源和其他一些参数组织而成。-->

08

<

dataNode

name

=

"dnTest1"

>

09

<

property

name

=

"dataSource"

>

10

<

dataSourceRef

>dsTest[0]</

dataSourceRef

>

11

</

property

>

12

</

dataNode

>

13

<

dataNode

name

=

"dnTest2"

>

14

<

property

name

=

"dataSource"

>

15

<

dataSourceRef

>dsTest[1]</

dataSourceRef

>

16

</

property

>

17

</

dataNode

>

18

<

dataNode

name

=

"dnTest3"

>

19

<

property

name

=

"dataSource"

>

20

<

dataSourceRef

>dsTest[2]</

dataSourceRef

>

21

</

property

>

22

</

dataNode

>

23

<!-- 数据源定义，数据源是一个具体的后端数据连接的表示。-->

24

<

dataSource

name

=

"dsTest"

type

=

"mysql"

>

25

<

property

name

=

"location"

>

26

<

location

>192.168.137.8:3306/dbtest1</

location

>

27

<

location

>192.168.137.31:3306/dbtest2</

location

>

28

<

location

>192.168.137.32:3306/dbtest3</

location

>

29

</

property

>

30

<

property

name

=

"user"

>cobar</

property

>

31

<

property

name

=

"password"

>sa</

property

>

32

<

property

name

=

"sqlMode"

>STRICT_TRANS_TABLES</

property

>

33

</

dataSource

>

34

</

cobar:schema

>

1

<!DOCTYPE cobar:server SYSTEM "server.dtd">

2

<

cobar:server

xmlns:cobar

=

"http://cobar.alibaba.com/"

>

3

<!-- 用户访问定义，用户名、密码、schema等信息。 -->

4

<

user

name

=

"root"

>

5

<

property

name

=

"password"

>sa</

property

>

6

<

property

name

=

"schemas"

>dbtest</

property

>

7

</

user

>

8

</

cobar:server

>

01

<!DOCTYPE cobar:rule SYSTEM "rule.dtd">

02

<

cobar:rule

xmlns:cobar

=

"http://cobar.alibaba.com/"

>

03

<!-- 路由规则定义，定义什么表，什么字段，采用什么路由算法 -->

04

<

tableRule

name

=

"rule1"

>

05

<

rule

>

06

<

columns

>val</

columns

>

07

<

algorithm

>

<![CDATA[ func2(${val}) ]]>

</

algorithm

>

08

</

rule

>

09

</

tableRule

>

10

<!-- 路由函数定义 -->

11

<

function

name

=

"func1"

class

=

"com.alibaba.cobar.route.function.PartitionByLong"

>

12

<

property

name

=

"partitionCount"

>2</

property

>

13

<

property

name

=

"partitionLength"

>512</

property

>

14

</

function

>

15

<!-- 路由函数定义 -->

16

<

function

name

=

"func2"

class

=

"com.alibaba.cobar.route.function.PartitionByString"

>

17

<

property

name

=

"partitionCount"

>2</

property

>

18

<

property

name

=

"partitionLength"

>512</

property

>

19

<

property

name

=

"hashSlice"

>-5:</

property

>

20

</

function

>

21

</

cobar:rule

>

01

yan@yan-Z400:~/cobar-server-1.2.7/logs$ tail -f stdout.log

02

09:57:00,155 INFOCobar is ready to startup ...

03

09:57:00,155 INFOStartup processors ...

04

09:57:00,198 INFOStartup connector ...

05

09:57:00,202 INFOInitialize dataNodes ...

06

09:57:00,811 INFOdnTest1:0 init success

07

09:57:00,816 INFOdnTest3:0 init success

08

09:57:00,821 INFOdnTest2:0 init success

09

09:57:00,835 INFOCobarManager is started and listening on 9066

10

09:57:00,837 INFOCobarServer is started and listening on 8066

11

09:57:00,837 INFO===============================================

01

yan@yan-Z400:~$ mysql -uroot -psa -P8066 -h192.168.137.8

02

Welcome to the MySQL monitor.Commands end with ; or \g.

03

Your MySQL connection id is 1

04

Server version: 5.1.48-cobar-1.2.7 Cobar Server (ALIBABA)

05

06

Copyright (c) 2000, 2013, Oracle and/or its affiliates. All rights reserved.

07

08

Oracle is a registered trademark of Oracle Corporation and/or its

09

affiliates. Other names may be trademarks of their respective

10

owners.

11

12

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

01

#!/usr/bin/env python

02

#coding=utf-8

03

import

MySQLdb

04

05

#连接

06

cxn

=

MySQLdb.Connect(host

=

'192.168.137.8'

,port

=

8066

, user

=

'root'

, passwd

=

'sa'

)

07

#游标

08

cur

=

cxn.cursor()

09

10

cur.execute(

"USE dbtest"

)

11

12

for

i

in

range

(

1

,

200

):

13

cur.execute(

"INSERT INTO tb2 (val) values ('this is a test record %d')"

%

i)

14

print

'insert the %d record into cobar'

%

i

15

16

cur.close()

17

cxn.commit()

18

cxn.close()