百度数据仓库 Palo - 查询
文档简介:
PALO 支持 Mysql 协议访问。您可以使用任意只用标准的 Mysql 客户端或程序库访问 PALO。
使用 MySQL 查询:
通过 MySQL 客户端连接到 PALO 以后,可以通过 show databases; 查看数据库。使用 use db_name; 选择数据库,使用 show tables; 查看数据库中的表。
PALO 支持 Mysql 协议访问。您可以使用任意只用标准的 Mysql 客户端或程序库访问 PALO。
使用 MySQL 查询
通过 MySQL 客户端连接到 PALO 以后,可以通过 show databases; 查看数据库。使用 use db_name; 选择数据库,使用 show tables; 查看数据库中的表。
mysql> show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| ssb |
+--------------------+
可以通过 help create database; 和 help create table; 查看建库和建表帮助。
执行查询的时候,只要直接输入SQL语句即可
mysql> select count(*) from lineorder; +----------+ | count(*) | +----------+ | 74046702
| +----------+ 1 row in set (0.68 sec)
使用 JDBC/ODBC 查询
可以使用 JDBC/ODBC 连接 PALO,连接 url 在集群信息页面可以获得。下面是 JDBC 的示例代码,需要使用 MySQL 的 JDBC 驱动
import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException;
public class Test { public static void main(String[] args) { // 加载驱动程序 try
{ Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { e.printStackTrace();
} // 创建数据库连接 java.sql.Connection conn = null; try { String url = "jdbc:mysql://your_cluster_node:9
030/testDb"; String user = "admin"; String password = "my_password"; conn = DriverManager.getConnection
(url, user, password); } catch (SQLException e) { e.printStackTrace(); } // 发起查询,取结果 java.sql.
Statement stmt = null; ResultSet rs = null; try { stmt = conn.createStatement(); rs = stmt.executeQuery
("select * from testTable limit 10"); while (rs.next()) { System.out.print(rs.getInt("k1") + " ");
System.out.println(rs.getString("k2") + " "); } } catch (SQLException e) { e.printStackTrace(); }
// 关闭数据库连接 try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } }