python 连接presto 并执行创建表的操作

可以使用 Python 中的 `presto-python-client` 库来连接 Presto 并执行操作。

首先，需要安装 `presto-python-client` 库：

pip install presto-python-client

然后，可以使用以下代码连接 Presto 并执行创建表的操作：

from presto import PrestoQuery

# 创建 PrestoQuery 对象，指定 Presto 服务器和端口
query = PrestoQuery(host='presto_server', port=8080)

# 执行创建表的 SQL 语句
create_table_sql = "CREATE TABLE my_table (id INT, name VARCHAR(50))"
query.execute(create_table_sql)

# 关闭连接
query.close()

其中，`presto_server` 是 Presto 服务器的主机名或 IP 地址，`8080` 是 Presto 服务器的端口号。`create_table_sql` 是要执行的 SQL 语句，可以根据需要修改。

执行完毕后，记得要调用 `close()` 方法关闭连接。

相关问题

python怎样连接trino

要在Python中连接Trino，可以使用PyHive或TrinoDB库。这里我们介绍一下使用PyHive连接Trino的方法：

1. 安装PyHive库

可以使用pip来安装PyHive库，命令如下：

pip install pyhive

2. 创建连接

在Python中使用PyHive连接Trino的代码如下：

from pyhive import trino

conn = trino.connect(host='your_trino_host', port=your_trino_port, username='your_username')

其中，需要替换`your_trino_host`和`your_trino_port`为Trino的主机名和端口号，`your_username`为连接Trino时使用的用户名。

3. 执行查询

连接成功后，可以使用`cursor()`方法创建游标对象，并使用`execute()`方法执行查询语句，例如：

cursor = conn.cursor()
cursor.execute('SELECT * FROM your_table')
rows = cursor.fetchall()

其中，`your_table`为要查询的表名。

4. 关闭连接

完成查询后，需要使用`close()`方法关闭连接：

conn.close()

需要注意的是，PyHive库底层使用的是Python DB API，因此可以通过修改连接字符串等方式来连接其他类型的数据库，例如Presto、Hive等。