Cypress web自动化36-cy.exec()执行python查询数据库获取结果

# 注意 这里是单引号，并不是标准的json类型
[{'name': 'test', 'sex': 'F', 'mail': '283340479@qq.com'}]

# json
[{"name": "test", "sex": "F", "mail": "283340479@qq.com"}]

# js object
[{name: "test", sex: "F", mail: "283340479@qq.com"}]

# select_sql.py
import pymysql

'''
环境安装
pip install PyMySQL==0.9.3
作者：上海-悠悠 交流QQ群:939110556
'''

dbinfo = {
    "host": "192.168.1.x",
    "user": "root",
    "password": "123456",
    "port": 3306}

class DbConnect():
    def __init__(self, db_cof, database=""):
        self.db_cof = db_cof
        # 打开数据库连接
        self.db = pymysql.connect(database=database,
                                  cursorclass=pymysql.cursors.DictCursor,
                                  **db_cof)

        # 使用cursor()方法获取操作游标
        self.cursor = self.db.cursor()

    def select(self, sql):
        # SQL 查询语句
        # sql = "SELECT * FROM EMPLOYEE \
        #        WHERE INCOME > %s" % (1000)
        self.cursor.execute(sql)
        results = self.cursor.fetchall()
        return results

    def execute(self, sql):
        # SQL 删除、提交、修改语句
        # sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
        try:
           # 执行SQL语句
           self.cursor.execute(sql)
           self.cursor.executemany()
           # 提交修改
           self.db.commit()
        except:
           # 发生错误时回滚
           self.db.rollback()

    def close(self):
        # 关闭连接
        self.db.close()

if __name__ == '__main__':
    import json
    sql = "select name,sex,mail from apiapp_userpersonalinfo where name='test';"
    db = DbConnect(dbinfo, database="apps")
    result = db.select(sql)
    db.close()
    # 以json格式输出到控制台
    print(json.dumps(result))

/**
 * Created by dell on 2020/5/11.
 * 作者：上海-悠悠 交流QQ群:939110556
 */

describe('执行系统命令查询sql', function() {
    beforeEach(() => {
      cy.exec("python D:\\Cypress\\cypress\\fixtures\\select_sql.py")
              .as("get_result")
              .then(function(result) {
                  // json解析成object
                const res_body = JSON.parse(result.stdout)
                //  示例：打印出来
                cy.log(res_body)
                // 断言 返回结果
                expect(res_body.length).to.be.at.least(1)
        })

        })

    it("查询结果当用例参数", function() {
        // json 解析
        cy.visit('https://www.cnblogs.com/yoyoketang')
        const res_json = JSON.parse(this.get_result.stdout)
        cy.log(res_json)

    })
    })