快速入门#

本文将介绍如何快速入门 OpenM(ysq)LDB。

安装部署可参考 OpenMLDB 部署文档 和 OpenM(ysq)LDB 部署文档。

使用兼容的 MySQL 命令行#

部署 OpenMLDB 分布式集群以后，开发者不需要额外安装 OpenMLDB 命令行工具，使用预安装好的 MySQL 命令行工具，可直接连接 OpenMLDB 集群进行测试（注意，下面的 SQL 连接以及执行结果，均在 OpenMLDB 集群中返回，并非远端 MySQL 服务）。

mysql-cli-1.png

通过执行定制化的 OpenMLDB SQL，我们不仅可以查看 OpenMLDB 集群状态，还可以切换离线模式和在线模式，实现 MLOps 的离线和在线特征抽取功能。

mysql-cli-2.png

使用兼容的 JDBC 驱动#

Java 用户一般使用 MySQL JDBC 驱动来连接 MySQL，同样的代码不需要任何修改就可以直连 OpenMLDB 集群。

编写 Java 应用代码如下，注意根据实际集群情况修改IP、端口以及用户名密码信息。

public class Main {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3307/db1";
        String user = "root";
        String password = "root";

        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;

        try {
            connection = DriverManager.getConnection(url, user, password);
            statement = connection.createStatement();

            resultSet = statement.executeQuery("SELECT * FROM db1.t1");

            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("ID: " + id + ", Name: " + name);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            // Close the result set, statement, and connection
            try {
                if (resultSet != null) {
                    resultSet.close();
                }
                if (statement != null) {
                    statement.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

然后编译执行即可，可以在命令行输出中看到查询的 OpenMLDB 数据库数据。

jdbc.png

使用兼容的 SQLAlchemy 驱动#

Python 用户常使用 SQLAlchemy 和 MySQL 驱动，同样的代码也可以直接用于查询 OpenMLDB 的在线数据。

编写 Python 应用代码如下：

from sqlalchemy import create_engine, text

def main():
    engine = create_engine("mysql+pymysql://root:root@127.0.0.1:3307/db1", echo=True)
    with engine.connect() as conn:
        result = conn.execute(text("SELECT * FROM db1.t1"))
        for row in result:
            print(row)

if __name__ == "__main__":
  main()

然后直接执行，在命令行也可以看到对应的 OpenMLDB 数据库输出。

sqlalchemy.png

使用兼容的 Go MySQL 驱动#

Golang 用户一般官方推荐的 github.com/go-sql-driver/mysql 驱动来访问 MySQL，同样不需要修改应用代码就可以直接访问 OpenMLDB 集群。

编写 Golang 应用代码如下：

package main

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

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

func main() {
        // MySQL database connection parameters
        dbUser := "root"         // Replace with your MySQL username
        dbPass := "root"         // Replace with your MySQL password
        dbName := "db1"    // Replace with your MySQL database name
        dbHost := "localhost:3307"        // Replace with your MySQL host address
        dbCharset := "utf8mb4"            // Replace with your MySQL charset

        // Create a database connection
        db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=%s", dbUser, dbPass, dbHost, dbName, dbCharset))
        if err != nil {
                log.Fatalf("Error connecting to the database: %v", err)
        }
        defer db.Close()

        // Perform a simple query
        rows, err := db.Query("SELECT id, name FROM db1.t1")
        if err != nil {
                log.Fatalf("Error executing query: %v", err)
        }
        defer rows.Close()

        // Iterate over the result set
        for rows.Next() {
                var id int
                var name string
                if err := rows.Scan(&id, &name); err != nil {
                        log.Fatalf("Error scanning row: %v", err)
                }
                fmt.Printf("ID: %d, Name: %s\n", id, name)
        }
        if err := rows.Err(); err != nil {
                log.Fatalf("Error iterating over result set: %v", err)
        }
}

直接编译并运行，即可在命令行查看数据库输出的结果。

go.png

使用兼容的 Sequel Ace 客户端#

MySQL 用户常用 GUI 应用来简化数据库的管理，用户如果想要连接 OpenMLDB 集群，也可以使用这类开源的 GUI 工具。

以 Sequel Ace 为例，用户不需要修改任何项目代码，只需要在连接数据库时，地址和端口填写 OpenM(ysq)LDB服务的地址和端口，用户名和密码填写OpenMLDB服务的用户名和密码，即可按照 MySQL 的操作方法来访问 OpenMLDB 服务。

sequel_ace.png