Skip to content

README.md

Latest commit

 

History

History
118 lines (96 loc) · 3.96 KB

README.md

File metadata and controls

118 lines (96 loc) · 3.96 KB

IoTDB-Spring-Boot-Starter Demo

Introduction

This demo shows how to use iotdb-spring-boot-starter

Version usage

IoTDB: 2.0.3
iotdb-spring-boot-starter: 2.0.3

1. Install IoTDB

please refer to [https://iotdb.apache.org/#/Download](https://iotdb.apache.org/#/Download)

2. Startup IoTDB

please refer to [Quick Start](http://iotdb.apache.org/UserGuide/Master/Get%20Started/QuickStart.html)

Then we need to create a database 'wind' by cli in table model
```
create database wind;
use wind;
```
Then we need to create a database 'table'
```
CREATE TABLE table1 (
    time TIMESTAMP TIME,
    region STRING TAG,
    plant_id STRING TAG,
    device_id STRING TAG,
    model_id STRING ATTRIBUTE,
    maintenance STRING ATTRIBUTE,
    temperature FLOAT FIELD,
    humidity FLOAT FIELD,
    status Boolean FIELD,
    arrival_time TIMESTAMP FIELD
) WITH (TTL=31536000000);
```

3. Build Dependencies with Maven in your Project

```
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.iotdb</groupId>
            <artifactId>iotdb-spring-boot-starter</artifactId>
            <version>2.0.3</version>
        </dependency>
    </dependencies>
```

4、Use The target Bean with @Autowired

You can use the target Bean in your Project,like:
```
    @Autowired
    private ITableSessionPool ioTDBSessionPool;
    @Autowired
    private SessionPool sessionPool;

    public void queryTableSessionPool() throws IoTDBConnectionException, StatementExecutionException {
        ITableSession tableSession = ioTDBSessionPool.getSession();
        final SessionDataSet sessionDataSet = tableSession.executeQueryStatement("select * from power_data_set limit 10");
        while (sessionDataSet.hasNext()) {
            final RowRecord rowRecord = sessionDataSet.next();
            final List<Field> fields = rowRecord.getFields();
            for (Field field : fields) {
                System.out.print(field.getStringValue());
            }
            System.out.println();
        }
    }

    public void querySessionPool() throws IoTDBConnectionException, StatementExecutionException {
        final SessionDataSetWrapper sessionDataSetWrapper = sessionPool.executeQueryStatement("show databases");
        while (sessionDataSetWrapper.hasNext()) {
            final RowRecord rowRecord = sessionDataSetWrapper.next();
            final List<Field> fields = rowRecord.getFields();
            for (Field field : fields) {
                System.out.print(field.getStringValue());
            }
            System.out.println();
        }
    }

```