# 使用程序访问数据库 {% hint style="info" %} 使用程序直接进行数据访问涉及较多的技术细节，适用于对相关功能有经验的用户参考。如果对文档内容有疑惑，请及时联系工作人员。 {% endhint %} ## JDBC #### JDBC 信息 | 字段 | 信息 | | ------------------- | --------------------------------------------------------------------------------------------- | | jdbc url | jdbc:presto://ark2.analysys.xyz:4285/hive/default | | driver | com.facebook.presto.jdbc.PrestoDriver | | user | daxiang | | SSL | true | | password | 编辑 /etc/presto/presto-auth.properties 文件查看 | | SSLKeyStorePath | presto.jks文件的路径，一般是/etc/presto/presto.jks | | SSLKeyStorePassword | 值可以在单机环境的ark1,集群环境的ark2的/etc/presto/config.properties文件中找到，对应http-server.https.keystore.key的值 | presto-jdbc.jar的下载地址： 如果使用代码访问，可以直接通过maven添加presto-jdbc的依赖，Maven 的依赖定义如下： ```markup com.facebook.presto presto-jdbc 0.201 ``` ```python 示例代码： Properties properties = new Properties(); properties.setProperty("user" , Config.prestoUsername); properties.setProperty("password" , Config.prestoPassword); properties.setProperty("SSL" , "true"); System.out.println(Config.class.getClassLoader().getResource("presto.jks").getPath()); properties.setProperty("SSLKeyStorePath" , Config.class.getClassLoader().getResource("presto.jks").getPath()); properties.setProperty("SSLKeyStorePassword" , Config.prestoSSLKeyStorePassword); Connection conn = null; try { Class.forName(driver); } catch (ClassNotFoundException e) { logger.error(ExceptionUtil.getMessage(e)); throw new RuntimeException("找不到jdbc驱动类", e); } conn = DriverManager.getConnection(url, parameter); return conn; ``` ## presto-shell 除了直接使用 JDBC 接口之外，也可以直接适用 presto-shell 工具进行查询。 直接登陆任意的方舟服务器，运行以下命令即可： ```bash #presto必须使用isuhadoop用户来连接 #集群环境 su - isuhadoop bin/presto-cli --server ark2:8285 #单机环境 su - isuhadoop bin/presto-cli --server ark1:8285 ``` ### 查询用户信息数据 #### 查看用户信息表的表结构 ```bash show create view hive.db_appid.profile_vd ``` #### 查询用户信息数据 ```bash select * from hive.db_appid.profile_vd limit 10 ``` 其中{appid}为要查询的appid ### 查询用户行为数据 #### 查看用户行为表的表结构 ```bash desc hive.db_appid.event_vd ``` #### 查询用户行为数据 ```bash select * from hive.db_appid.event_vd limit 10 ``` 其中{appid}为要查询的appid ### 数据导出 #### 导出不包含表头的CSV格式的文件 ```bash #集群环境 presto-cli --server ark2:8285 --execute 'select * from hive.db_{appid}.event_vd limit 10' --output-format CSV > dataFile.CSV presto-cli --server ark2:8285 --execute 'select * from chbase.db_{appid}.profile limit 10' --output-format CSV > dataFile.CSV #单机环境 presto-cli --server ark1:8285 --execute 'select * from hive.db_{appid}.event_vd limit 10' --output-format CSV > dataFile.CSV presto-cli --server ark1:8285 --execute 'select * from chbase.db_{appid}.profile limit 10' --output-format CSV > dataFile.CSV ``` {appid}为要查询项目的appid dataFile.CSV为导出的文件路径 #### 导出包含表头的CSV格式的文件 ```bash #集群环境 presto-cli --server ark2:8285 --execute 'select * from hive.db_{appid}.event_vd limit 10' --output-format CSV_HEADER > dataFile.CSV_HEADER presto-cli --server ark2:8285 --execute 'select * from chbase.db_{appid}.profile limit 10' --output-format CSV_HEADER > dataFile. CSV_HEADER #单机环境 presto-cli --server ark1:8285 --execute 'select * from hive.db_{appid}.event_vd limit 10' --output-format CSV_HEADER > dataFile.CSV_HEADER presto-cli --server ark1:8285 --execute 'select * from chbase.db_{appid}.profile limit 10' --output-format CSV_HEADER > dataFile. CSV_HEADER ``` {appid}为要查询项目的appid dataFile.CSV为导出的文件路径 数据第一行为表头 #### 导出不包含表头的TSV格式的文件–没有表头 ```bash presto-cli --server ark2:8285 --execute 'select * from hive.db_{appid}.event_vd limit 10' --output-format TSV > dataFile.TSV presto-cli --server ark2:8285 --execute 'select * from chbase.db_{appid}.profile limit 10' --output-format TSV > dataFile. TSV ``` {appid}为要查询项目的appid dataFile.CSV为导出的文件路径 字段间以tab键分割 #### 导出包含表头的TSV格式的文件 ```bash presto-cli --server ark2:8285 --execute 'select * from hive.db_{appid}.event_vd limit 10' --output-format TSV_HEADER > dataFile.TSV_HEADER presto-cli --server ark2:8285 --execute 'select * from chbase.db_{appid}.profile limit 10' --output-format TSV_HEADER > dataFile.TSV_HEADER ``` {appid}为要查询项目的appid dataFile.CSV为导出的文件路径 数据第一行为表头，字段间以tab键分割 其他格式，请参考 presto-cli --help 命令中--output-format 选项的说明。 ## Python 如果你更熟悉 python，也可以通过 [presto-python-client](https://pypi.org/project/presto-python-client/) 来对数据库进行访问。 ### 连接方法 ```python import prestodb conn=prestodb.dbapi.connect( host='ip address of ark2', port=8285, user='daxiang', catalog='hive', schema='db_{appkey}', ) cur = conn.cursor() cur.execute('SELECT * FROM event_vd limit 10') rows = cur.fetchall() print rows ``` ## R 可以尝试使用开源项目 来对数据库进行访问。 ## Metabase Metabase 是类似 HUE（自定义查询） 的开源查询界面，如果你想直接通过 SQL 查询，而不想用 HUE 的话也可以用它直接连接方舟的 Presto。 下载地址：
#### 配置参数说明 **Name**：自定义数据源名称，方便后续识别 **Host：**方舟 Presto 的服务器IP，一般为内网IP（ 如何查找？登录Ambari ——点击Presto ——点击Presto coordinator 找到想要查找数据的服务器） ![](/files/-MMKiM6lBocwY8X_XYH6) **Port：**8285 （固定值） **Database Name：**hive （固定值，注意全部小写字母） **Database username：** streaming （固定值） 下方的三个开关保持默认，点击底部的确认按钮即可完成连接配置。 {% hint style="warning" %} 若确认后看不到数据表，请关闭 Metabase 重新进入 {% endhint %} {% hint style="info" %} 以上内容没有解答我的问题？[点击我进入方舟论坛去反馈](https://www.analysysdata.com/forum/index) 🚀 {% endhint %} --- # Agent Instructions: Querying This Documentation If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question. Perform an HTTP GET request on the current page URL with the `ask` query parameter: ``` GET https://arkdocs.analysys.cn/integration/open-original-export/program.md?ask= ``` The question should be specific, self-contained, and written in natural language. The response will contain a direct answer to the question and relevant excerpts and sources from the documentation. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.