更新时间:2024-10-31 GMT+08:00
分享

向Doris表中插入数据

本章节介绍向Doris表中插入数据样例代码。

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

以Java JDBC方式执行SQL语句在集群的dbName.tableName表中插入数据。

String insertTableSql = "insert into " + dbName + "." + tableName + " values(?, ?, ?)";
private static void insert(Connection connection, String sql) throws Exception {
   int INSERT_BATCH_SIZE = 10;
   try(PreparedStatement stmt = connection.prepareStatement(sql)) {
      for (int i =0; i < INSERT_BATCH_SIZE; i++) {
         stmt.setInt(1, i);
         stmt.setInt(2, i * 10);
         stmt.setString(3, String.valueOf(i * 100));
         stmt.addBatch();
      }
      stmt.executeBatch();
   } catch (Exception e) {
      logger.error("Execute sql {} failed.", sql, e);
      throw new Exception(e);
   }
}

相关文档