Golang数据库代理插件WeScale提升应用扩展性与性能

WeScale简介

WeScale是一个开源的数据库代理，专为应用开发者设计。它旨在简化和增强应用程序与数据库之间的交互，使开发更高效、更愉快。

主要特性

WeScale作为数据库代理，在应用层和数据库层之间起着关键桥梁作用。它倾向于应用侧，提供了专门设计的功能来简化开发者体验：

• 声明式DDL
• 在线DDL
• 事务分割
• 过滤器
• 编写Wasm插件
• 分支功能
• 透明故障转移
• 读写分离和负载均衡
• 读写一致性

快速开始

使用Docker启动WeScale

# 创建网络
docker network create wescale-network

# 启动MySQL服务器
docker run -itd --network wescale-network --name mysql-server \
  -p 3306:3306 \
  -e MYSQL_ROOT_PASSWORD=passwd \
  -e MYSQL_ROOT_HOST=% \
  -e MYSQL_LOG_CONSOLE=true \
  mysql/mysql-server:8.0.32 \
  --bind-address=0.0.0.0 \
  --port=3306 \
  --log-bin=binlog \
  --gtid_mode=ON \
  --enforce_gtid_consistency=ON \
  --log_replica_updates=ON \
  --binlog_format=ROW

# 启动WeScale
docker run -itd --network wescale-network --name wescale \
  -p 15306:15306 \
  -w /vt/examples/wesql-server \
  -e MYSQL_ROOT_USER=root \
  -e MYSQL_ROOT_PASSWORD=passwd \
  -e MYSQL_PORT=3306 \
  -e MYSQL_HOST=mysql-server \
  apecloud/apecloud-mysql-scale:0.3.8 \
  /vt/examples/wesql-server/init_single_node_cluster.sh

连接WeScale和MySQL

# 连接WeScale
mysql -h127.0.0.1 -uroot -ppasswd -P15306

# 也可以直接连接原始MySQL服务器
mysql -h127.0.0.1 -uroot -ppasswd -P3306

尝试声明式DDL

SET @@enable_declarative_ddl=true;

CREATE DATABASE if not exists test;
USE test;

CREATE TABLE if not exists test_table (
    id int primary key,
    name varchar(255)
);

SHOW CREATE TABLE test_table;

CREATE TABLE if not exists test_table (
    id int primary key,
    name varchar(255),
    email varchar(255),
    profile varchar(255),
    index (name, email)
);

SHOW CREATE TABLE test_table;

清理容器

docker rm -f mysql-server wescale
docker network rm wescale-network

Golang示例代码

以下是一个使用Go连接WeScale的完整示例：

package main

import (
	"database/sql"
	"fmt"
	"log"

	_ "github.com/go-sql-driver/mysql"
)

func main() {
	// 连接WeScale代理
	db, err := sql.Open("mysql", "root:passwd@tcp(127.0.0.1:15306)/test")
	if err != nil {
		log.Fatal(err)
	}
	defer db.Close()

	// 测试连接
	err = db.Ping()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("成功连接到WeScale代理!")

	// 创建表
	_, err = db.Exec(`
		CREATE TABLE IF NOT EXISTS users (
			id INT PRIMARY KEY,
			name VARCHAR(50),
			email VARCHAR(50)
		)`)
	if err != nil {
		log.Fatal(err)
	}

	// 插入数据
	_, err = db.Exec("INSERT INTO users (id, name, email) VALUES (?, ?, ?)", 
		1, "张三", "zhangsan@example.com")
	if err != nil {
		log.Fatal(err)
	}

	// 查询数据
	rows, err := db.Query("SELECT id, name, email FROM users")
	if err != nil {
		log.Fatal(err)
	}
	defer rows.Close()

	for rows.Next() {
		var id int
		var name, email string
		err = rows.Scan(&id, &name, &email)
		if err != nil {
			log.Fatal(err)
		}
		fmt.Printf("ID: %d, Name: %s, Email: %s\n", id, name, email)
	}
}

监控

WeScale启动运行后，可以使用Prometheus和Grafana监控集群：

cd ./examples/metrics && ./start_dashboard.sh

然后在浏览器中访问http://localhost:3000/dashboards查看仪表板。

社区与贡献

欢迎加入WeScale社区讨论功能、获取帮助并与其他用户交流。我们也欢迎任何形式的贡献，如果您有任何想法、错误报告或功能请求，请随时提交issue或pull request。

许可证

WeScale基于Apache 2.0许可证发布。