基于 DolphinDB 搭建 SpringBoot 微服务

SpringBoot 是建立微服务的首选框架，而 DolphinDB 在大数据场景下的高性能时序分析能力也越来越受到关注。这篇文章以最小化配置、快速上手为目标。演示如何在 SpringBoot 项目中集成 MyBatis 与 DolphinDB，并实现基础与特殊类型的增删改查。

一、环境与项目初始化

1️⃣ 典型痛点：依赖选择与版本冲突

• 在 Spring Initializr 里默认依赖往往不包含 DolphinDB JD娱乐；需要手动添加，
• Maven 对象模型中若未正确指定com.dolphindb.jdbc版本，IDE 会报错找不到驱动。

步骤的观点是，

groupId : com.dolphindb
artifactId : demo
dependencies : Lombok。Spring Web,MyBatis Framework

下载并使用 IDE打开项目后右键刷新 Maven。接下来新建标准 MVC 目录结构：

src/main/java/com/dolphindb/demo
├─ controller
├─ service
│ └─ impl
├─ dao
└─ mapper

2️⃣ 配置 DolphinDB JD娱乐 驱动

在 pom.xml 添加：

com.dolphindb
jdbc

刷新 Maven 后驱动可用。

3️⃣ application.properties 关键配置

server.port=8080
spring.datasource.url=jdbc:dolphindb://localhost:96?user=admin&password=&databasePath=dfs://example
spring.datasource.username=admin
spring.datasource.driver-class-name=com.dolphindb.jdbc.Driver
mybatis.mapper-locations=classpath:/mapper/*.xml
mybatis.configuration.auto-mapping-behavior=full
mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

二、数据库准备与表结构创建

Pain Point：脚本复杂、分区设计难度大

DolphinDB 的分区表需要提前预设分区列和存储引擎。以下脚本演示创建一个多类型字段的分区表：

colName = `BoolValue`CharValue`ShortValue`IntValue`LongValue...
colType =
t = table
engine = "TSDB"
dbName = "dfs://example"
tbName = "example"
years = sort))
directory = dbNamedb
db = database
createPartitionedTable

运行后可在 DolphinDB 控制台执行：

select * from loadTable

三、实体映射与基础 CRUD 接口实现

Pain Point：Java 与 DolphinDB 类型不匹配导致插入失败或查询错误。

• DolphinDB 的 BOOL → Java Boolean 等对应关系需严格遵守。
• Date/Time 类型转换尤其容易出错，建议统一使用 Java 8+ 的时间 API。

# 实体类 ExampleEntity.java

@Data
public class ExampleEntity {
private Boolean boolValue;private Byte charValue;private Short shortValue;private Integer intValue;private Long longValue;private LocalDate date;private Date time;private LocalTime second;private LocalDateTime datetime;private LocalDateTime timestamp;private LocalDateTime nanotime;private LocalDateTime nanotimestamp;private LocalTime minute;private Float floatValue;private Double doubleValue;private String symbol;private String string;private LocalDateTime dateHour;不过，private String blob;其实，}

# DAO 接口 ExampleDao.java

@Mapper
public interface ExampleDao {
void insertExampleData;List getExampleData;// 更多查询/更新/删除方法...
}

# Mapper XML 示例

insert into loadTable
values(
#{boolValue},#{charValue},#{shortValue},#{intValue},#{longValue},#{date},#{time},#{second},#{datetime},#{timestamp}。#{nanotime},#{nanotimestamp},#{minute},#{floatValue},#{doubleValue},#{symbol},#{string},#{dateHour},#{blob})

# Service 与 Controller 层示例

• ServiceImpl: 调用 DAO 方法。其实，
• Controller: 提供 REST 接口。例如 POST /insertExampleData。
• Pain Point：请求 JSON 字段命名需严格与实体类保持一致，否则会出现空值或转换错误。 怎么说呢，
• Pain Point：返回状态码及消息需统一。以便前端统一处理，
• Pain Point：异常处理缺失会导致接口返回堆栈信息泄露。
• Pain Point：跨域请求若未配置会被浏览器拦截。
• Pain Point：请求参数校验不足可能导致无效数据写入数据库。建议使用 @Valid 并结合自定义校验注解。java @PostMapping public ResponseEntity insert{ exampleService.insert;return ResponseEntity.ok;}

  ---

  *

  四、特殊类型支持

  A. DECIMAL 类型

  痛点这方面。

  • DECIMAL 在 JD娱乐 中只能作为字符串传递，Java 内部无法直接解析为 BigDecimal。
  • 查询时需要显式将字符串转为数值才能比较一下。

  至于实现方式，

  1. 实体类 java @Data public class DecimalTableEntity { @JsonFormatprivate LocalDate date;@JsonDeserialize @JsonSerialize BigDecimal decimal32;老实说，}
  2. Mapper xml
  select * from loadTable where Date=#{date}

  3. 自定义序列化/反序列化保证 JSON ↔︎ Java 对象互转正确。

  B. ArrayVector 类型

  从痛点来看。

  • JD娱乐 未提供内置的数组类型处理，需要自定义 TypeHandler。
  • 时间戳数组需手工解析毫秒值。

  再看实现方式，

  1. 自定义 TypeHandler java public class IntArrayTypeHandler extends BaseTypeHandler { …} public class DoubleArrayTypeHandler extends BaseTypeHandler { …} public class TimestampArrayTypeHandler extends BaseTypeHandler { …}
  2. application.properties properties mybatis.type-handlers-package=com.dolphindb.demo.handler
  3. 实体类 java @Data public class ArrayTableEntity { @JsonFormatprivate LocalDate date;int arrayInt;double arrayDouble;LocalDateTime arrayTimestamp;}
  4. Mapper / Service / Controller 使用普通 CRUD 方法即可。

  C. upsert!操作

  再看痛点，

  • 正确识别主键并避免重复插入是主要难点。
  • 高并发场景下需要事务控制。

  说到实现方式，

  1. DAO 方法 xml exampleTmpTable = table foreach collection='list' item='item' insert into exampleTmpTable values endfor upsert!,exampleTmpTable，);end
  2. Service 层包装 调用 DAO 并返回受影响行数。

  五、接口设计要点

  功能	请求方式	方法	参数说明	返回
  插入	POST	/insertExampleData	JSON body	200 OK + "插入成功"
  查询所有	GET	/getExampleData	无	列表
  按日期查询	GET	/getExampleDataByDate?date=	日期参数	列表
  更新按日期范围	PUT	/updateExampleDataByDate?start=&end=	JSON body + 日期参数	行数
  删除按日期	DELETE	/deleteExampleDataByDate?date=		行数

  六、常见问题汇总

  • DolphinDB 驱动不可用：
    • “dsp:mysql:mysqlclient.jar”…其实，
    • “NoClassDefFoundError com/dolphindb/jdbc/Driver”…
    请确保 pom.xml 中已声明正确依赖并执行 mvn clean install。 如果仍报错，请检查 JDK 与 JD娱乐 驱动兼容性。 --> -->