Menggunakan MyCat untuk pembahagian pangkalan data dalam pembangunan API Java

Dengan perkembangan pesat Internet, keperluan penyimpanan pangkalan data telah meningkat dengan pesat Cara mengoptimumkan kecekapan membaca dan menulis pangkalan data serta meningkatkan kelajuan membaca dan menulis telah menjadi masalah bagi setiap pembangun. Teknologi pembahagian pangkalan data adalah salah satu cara yang paling biasa dan berkesan untuk menyelesaikan masalah ini.

MyCat ialah perisian tengah pangkalan data teragih berdasarkan MySQL Ia menyokong penghuraian dan pelaksanaan transaksi dan pernyataan SQL, dan menyediakan fungsi seperti replikasi induk-hamba, pengasingan baca-tulis dan orkestrasi nod teragih. Banyak ciri MyCat adalah serupa dengan Sharding-JDBC, menyokong serpihan automatik, pemisahan baca-tulis, penemuan dan pemulihan kerosakan automatik, dan pengimbangan beban serpihan Pada masa yang sama, MyCat juga menyokong penghantaran telus yang diedarkan dan virtualisasi pangkalan data berbilang dimensi boleh memenuhi keperluan storan data berskala besar dan membaca dan menulis.

Java API ialah antara muka API bahasa pengaturcaraan Java Pembangun boleh menggunakan Java API untuk operasi pangkalan data dan pemprosesan data. Yang berikut akan menunjukkan cara menggunakan MyCat untuk pembahagian pangkalan data dalam pembangunan API Java.

1. Pasang MyCat

Mula-mula anda perlu memuat turun dan memasang MyCat Anda boleh pergi ke laman web rasmi http://www.mycat.io/ selepas pemasangan selesai , mulakan perkhidmatan MyCat.

2. Konfigurasikan MyCat

Ubah suai fail konfigurasi MyCat mycatserver/conf/server.xml dan tetapkan dasar capaian nod pangkalan data dan shard yang sepadan, seperti berikut:

<?xml version="1.0"?>
<!DOCTYPE server SYSTEM "server.dtd">
<server>
  <system>
    <!-- 全局参数设置 -->
    <property name="useSqlStat" value="false" />
  </system>
  <!-- 读写分离配置 -->
  <user name="root">
    <property name="password">root</property>
    <!-- 读写分离 -->
    <property name="readNode" value="dn1,dn2" />
    <property name="writeNode" value="dn1,dn2" />
  </user>
  <!-- Mycat分片配置 -->
  <dataHost name="dh1" maxCon="1000" minCon="2" balance="0"
            writeType="0" dbType="mysql" dbDriver="native" switchType="1"
            slaveThreshold="100">
    <heartbeat>select user()</heartbeat>
    <writeHost host="mysql1" url="192.168.1.101:3306" user="root2" password="root2">
      <!--读写分离-->
      <readHost host="mysql1" url="192.168.1.101:3306"
                user="root2" password="root2" />
      <readHost host="mysql2" url="192.168.1.102:3306"
                user="root2" password="root2" />
    </writeHost>
    <writeHost host="mysql2" url="192.168.1.102:3306" user="root2" password="root2">
      <!--读写分离-->
      <readHost host="mysql1" url="192.168.1.101:3306"
                user="root2" password="root2" />
      <readHost host="mysql2" url="192.168.1.102:3306"
                user="root2" password="root2" />
    </writeHost>
  </dataHost>
  <dataNode name="dn1" dataHost="dh1" database="test" />
  <dataNode name="dn2" dataHost="dh1" database="test" />
  <!--分片规则配置，定义了t_user 表的分片策略-->
  <tableRule name="t_user" dataNode="dn1,dn2" ruleType="mod" startShardKey="id"
             endShardKey="id" />
  <!--schema配置，schema可以看成是单独的mysql实例-->
  <schema name="test" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1,dn2" />
</server>

di atas Dalam fail konfigurasi, kami mentakrifkan nod data dh1, yang mempunyai dua nod tulis mysql1 dan mysql2, dan nod baca masing-masing. Selain itu, kami juga mengkonfigurasikan peraturan pembahagian jadual: jadual t_user terdiri daripada dua nod data dn1 dan dn2, dan dipecahkan mengikut id. Akhir sekali, gunakan teg skema untuk mengkonfigurasi pangkalan data yang diperlukan.

3. Gunakan MyCat JDBC untuk menyambung ke MySQL

Dalam kod Java, kami boleh menggunakan pemacu JDBC MyCat untuk menyambung ke pangkalan data MySQL dan menggunakan MyCat untuk melaksanakan fungsi sharding. Format URL sambungan adalah seperti berikut:

jdbc:mysql://localhost:8066/dbName?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT

Di mana, localhost ialah nama hos di mana MyCat terletak , 8066 ialah nombor port MyCat, dan dbName ialah nama pangkalan data yang perlu disambungkan. Anda perlu menggunakan pemacu JDBC MyCat apabila menyambung Kodnya adalah seperti berikut:

String url = "jdbc:mysql://localhost:8066/mycatdb?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT";
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection(url, "root", "root");

Dalam kod, kami memuatkan pemacu JDBC MyCat melalui Class.forName(), dan kemudian gunakan DriverManager.getConnection() untuk mewujudkan sambungan dengan sambungan Pangkalan Data MySQL.

4. Cipta jadual berpecah

Menggunakan MyCat, anda boleh membuat jadual berpecah secara logik. Semasa mereka bentuk jadual, ia perlu dibahagikan kepada berbilang jadual fizikal, dan setiap jadual fizikal disimpan pada pangkalan data yang berbeza Di Java, kita perlu menggunakan pernyataan CREATE TABLE untuk mencipta jadual berpecah, seperti berikut:

CREATE TABLE t_user (
  id BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
  name VARCHAR(32) NOT NULL,
  PRIMARY KEY (id)
)
PARTITION BY KEY(id)
PARTITIONS 4;

Dalam kod di atas, kami menggunakan pernyataan PARTITION BY KEY(id) untuk mentakrifkan peraturan sharding jadual, dan menggunakan PARTITIONS 4 untuk mentakrifkan jadual kepada 4 shards.

5. Masukkan data ke dalam jadual berpecah

Dalam kod Java, menggunakan jadual MyCat sharded adalah sama dengan jadual MySQL biasa Anda hanya perlu menggunakan pernyataan INSERT untuk memasukkan ke dalam Jadual. Data sudah mencukupi, seperti berikut:

Statement stmt = conn.createStatement();
stmt.executeUpdate("INSERT INTO t_user (name) VALUES ('tom')");
stmt.executeUpdate("INSERT INTO t_user (name) VALUES ('jerry')");

Melalui kaedah executeUpdate() objek Pernyataan, kita boleh memasukkan data bernama tom dan jerry ke dalam jadual t_user MyCat akan menyimpan data secara automatik jadual sharded mengikut peraturan sharding dalam jadual fizikal sharded yang sepadan.

6. Soal data dalam jadual sharded

Gunakan MyCat untuk menanyakan data jadual sharded dalam kod Java. Anda hanya perlu menggunakan SELECT pernyataan, seperti berikut:

Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery("SELECT * FROM t_user");
while(rs.next()) {
    long id = rs.getLong("id");
    String name = rs.getString("name");
    System.out.printf("id: %d, name: %s
", id, name);
}

Menggunakan kaedah next() objek ResultSet, kita boleh melintasi set hasil pertanyaan dan mendapatkan hasil pertanyaan melalui kaedah getXXX()nya.

Di atas ialah langkah terperinci dan kod sampel untuk menggunakan MyCat untuk pembahagian pangkalan data dalam pembangunan API Java. MyCat menyediakan strategi sharding yang sangat lengkap dan pelbagai ciri Dalam senario dengan penyimpanan pangkalan data berskala besar dan keperluan membaca dan menulis, menggunakan MyCat untuk sharding pangkalan data secara berkesan boleh meningkatkan kecekapan operasi pangkalan data dan kelajuan membaca dan menulis.

Atas ialah kandungan terperinci Menggunakan MyCat untuk pembahagian pangkalan data dalam pembangunan API Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!