Skip to content

Python 连接

MatrixOne 支持 Python 连接,支持 pymysqlsqlalchemy 两种驱动程序。

本篇文档将指导你了解如何通过这两个 python 驱动程序连接 MatrixOne。

开始前准备

#检查 Python 版本号,确认是否安装
python3 -V
  • 已安装 MySQL 客户端。

使用 pymysql 工具连接 MatrixOne 服务

PyMySQL 是一个纯 Python MySQL 客户端库。

  1. 下载安装 pymysql 和 cryptography 工具:

    pip3 install pymysql
    pip3 install cryptography
    
    #If you are in China mainland and have a low downloading speed, you can speed up the download by following commands.
    pip3 install pymysql -i https://pypi.tuna.tsinghua.edu.cn/simple
    pip3 install cryptography -i https://pypi.tuna.tsinghua.edu.cn/simple
    
  2. 使用 MySQL 客户端连接 MatrixOne。新建一个名称为 test 数据库:

    mysql> create database test;
    
  3. 创建一个纯文本文件 pymysql_connect_matrixone.py 并将代码写入文件:

    #!/usr/bin/python3
    
    import pymysql
    
    # Open database connection
    db = pymysql.connect(
            host='127.0.0.1',
            port=6001,
            user='root',
            password = "111",
            db='test',
            )
    # prepare a cursor object using cursor() method
    cursor = db.cursor()
    
    # execute SQL query using execute() method.
    cursor.execute("SELECT VERSION()")
    
    # Fetch a single row using fetchone() method.
    data = cursor.fetchone()
    print ("Database version : %s " % data)
    
    # disconnect from server
    db.close()
    
  4. 打开一个终端,在终端内执行下面的命令:

    > python3 pymysql_connect_matrixone.py
    Database version : 8.0.30-MatrixOne-v2.0.0
    

使用 sqlalchemy 连接 MatrixOne

SQLAlchemy 是 Python SQL 工具包和对象关系映射器 (ORM),它为应用开发人员提供了 SQL 的全部功能。

  1. 下载并安装 sqlalchemy 工具,下载代码示例如下:

    pip3 install sqlalchemy
    
    #If you are in China mainland and have a low downloading speed, you can speed up the download by following commands.
    pip3 install sqlalchemy -i https://pypi.tuna.tsinghua.edu.cn/simple
    
  2. 使用 MySQL 客户端连接 MatrixOne。新建一个名称为 test 数据库,并且新建一个名称为 student 表,然后插入两条数据:

    mysql> create database test;
    mysql> use test;
    mysql> create table student (id int primary key,name varchar(20), age int);
    mysql> insert into student values (1,"tom", 11), (2,"alice", "10");
    
  3. 创建一个纯文本文件 sqlalchemy_connect_matrixone.py 并将代码写入文件:

    from sqlalchemy import create_engine
    from sqlalchemy.orm import declarative_base as _declarative_base
    from sqlalchemy import Column, Integer, String
    from sqlalchemy.orm import sessionmaker
    
    #使用 SQLAlchemy 创建到 MatrixOne 的连接字符串,并创建一个引擎(Engine)
    connection_string = 'mysql+pymysql://root:111@127.0.0.1:6001/test'
    engine = create_engine(connection_string)
    
    Base = _declarative_base()
    
    #定义一个 Python 类来映射 student 表。
    class Student(Base):
        __tablename__ = 'student'
        id = Column(Integer, primary_key=True)
        name = Column(String)
        age = Column(Integer)
    
    #使用 sessionmaker 创建一个会话来执行查询
    Session = sessionmaker(bind=engine)
    session = Session()
    
    #使用 SQLAlchemy 的查询接口来查询 student 表中的数据。
    users = session.query(Student).all()
    for user in users:
        print(f'ID: {user.id}, Name: {user.name}, Age: {user.age}')
    
  4. 打开一个终端,在终端内执行下面的命令:

    python3 sqlalchemy_connect_matrixone.py
    ID: 1, Name: tom, Age: 11
    ID: 2, Name: alice, Age: 10