MAPREDUCE服务 MRS-创建Doris表

时间：2024-10-22 10:49:51

MAPREDUCE服务 MRS

创建Doris表

本章节介绍创建Doris表样例代码。

以下代码片段在“JDBCExample”类中。

以Java JDBC方式执行SQL语句在集群中dbName变量对应的数据库下创建tableName对应的表。

String createTableSql = "create table if not exists " + dbName + "." + tableName +  " (\n" +
      "c1 int not null,\n" +
      "c2 int not null,\n" +
      "c3 string not null\n" +
      ") engine=olap\n" +
      "unique key(c1, c2)\n" +
      "distributed by hash(c1) buckets 1";

public static void execDDL(Connection connection, String sql) throws Exception {
   try (PreparedStatement statement = connection.prepareStatement(sql)) {
      statement.execute();
   } catch (Exception e) {
      logger.error("Execute sql {} failed.", sql, e);
      throw new Exception(e);
   }
}

父主题： Doris JDBC接口调用样例程序

上一篇：MAPREDUCE服务 MRS-准备连接Doris集群配置文件:配置运行环境网络

下一篇：MAPREDUCE服务 MRS-Spark应用开发简介:Structured Streaming常用概念