在0.3秒内在数据库中进行十亿次操作。不要将OLTP与OLAP进行比较，而将QuestDB与PostgreSQL进行比较

什么影响数据库的选择

• 实时交易处理或在线分析处理
  
• 垂直或水平扩展
• 在分布式基础上-数据一致性/可用性/抗分离性（CAP定理）
• 特定的数据方案和数据库或存储中不需要数据方案的限制
  
• 数据模型-键值，层次结构，图形，文档或关系型
• 处理逻辑尽可能接近数据或应用程序中的所有处理
• 主要在RAM或磁盘子系统中工作
• 通用解决方案或专业
• 我们在数据库中使用了不适合项目要求的现有专业知识，或者在适当但不熟悉的培训中“血汗”开发了一个新的专家（这不仅适用于开发，而且适用于操作）
  
• 内置或在其他进程/网络中
• 潮人或逆行

• “外星人”查询语言
• 唯一的用于处理数据库的本机API，这会使向其他数据库的转换复杂化（花费了时间，团队精力和项目预算）
• 其他平台/语言/操作系统的驱动程序不可用
• 缺少源代码，磁盘上数据格式的描述（或禁止使用逆向工程许可，尤其是具有Coherence缺陷的Oracle）
• 许可证成本逐年增长
• 自己的生态系统和寻找专家的困难
• , ,

QuestDB

• 尝试最大程度地利用硬件来执行分析查询-聚合函数的矢量化，通过内存映射文件处理数据
• SQL作为DML查询和DDL操作的语言，用于管理数据库结构
• 支持特定于时间序列数据库的联接表
• 支持SQL中的窗口和聚合功能
• 在JVM上的应用程序中嵌入数据库的能力
• JVM, ServiceLoader
• Influx DB line protocol (ILP) UDP Telegraf. «What makes QuestDB faster than InfluxDB»
• PostgreSql 11 PostgreSQL: JDBC, ODBC psql
  
• web - REST endpoint , SQL json
  
• ,
  
• zero-GC API, .
  
• ( )
  
• 64 Windows, Linux, OSX, ARM Linux FreeBSD
  
• , open source,

SIMD操作

运行docker数据库镜像

docker pull questdb/questdb

docker run --rm -it -p 9000:9000 -p 8812:8812 questdb/questdb

Jdbc访问

import org.junit.jupiter.api.Test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

import static org.assertj.core.api.Assertions.*;

public class QuestDbDriverTest {

    @Test
    void containerIsUpTestByJdbcInvocation() throws Exception {
        try (Connection connection = DriverManager.getConnection("jdbc:tc:questdb:///?user=admin&password=quest")){
            try (Statement statement = connection.createStatement()){
                try (ResultSet resultSet = statement.executeQuery("select 42 from long_sequence(1)")){
                    resultSet.next();
                    assertThat(resultSet.getInt(1)).isEqualTo(42);
                }
            }
        }
    }
}

import io.questdb.ServerMain;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;

import java.nio.file.Path;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.Statement;

public class QuestDbJdbcTest {
    @Test
    void embeddedServerStartTest(@TempDir Path tempDir) throws Exception{
        ServerMain.main(new String[]{"-d", tempDir.toString()});
        try (DriverManager.getConnection("jdbc:postgresql://localhost:8812/", "admin", "quest")){
            try (Statement statement = connection.createStatement()){
                try (ResultSet resultSet = statement.executeQuery("select 42 from long_sequence(1)")){
                    resultSet.next();
                    assertThat(resultSet.getInt(1)).isEqualTo(42);
                }
            }
        }
    }
}

嵌入Java应用程序

import io.questdb.cairo.CairoEngine;
import io.questdb.cairo.DefaultCairoConfiguration;
import io.questdb.griffin.CompiledQuery;
import io.questdb.griffin.SqlCompiler;
import io.questdb.griffin.SqlExecutionContextImpl;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.io.TempDir;

import java.nio.file.Path;

public class TruncateExecuteTest {
    @Test
    void truncate(@TempDir Path tempDir) throws Exception{
        SqlExecutionContextImpl executionContext = new SqlExecutionContextImpl();
        DefaultCairoConfiguration configuration = new DefaultCairoConfiguration(tempDir.toAbsolutePath().toString());
        try (CairoEngine engine = new CairoEngine(configuration)) {
            try (SqlCompiler compiler = new SqlCompiler(engine)) {
                CompiledQuery createTable = compiler.compile("create table tr_table(id long,name string)", executionContext);
                compiler.compile("truncate table tr_table", executionContext);
            }
        }
    }
}

网络控制台

您是否需要另一个数据库？