مليار عملية في قاعدة البيانات في 0.3 ثانية. لا تقارن OLTP مع OLAP ، لكن QuestDB مع PostgreSQL

ما يؤثر على اختيار قاعدة البيانات

• معالجة المعاملات في الوقت الحقيقي أو المعالجة التحليلية عبر الإنترنت
  
• قابل للتطوير رأسيًا أو أفقيًا
• في حالة القاعدة الموزعة - اتساق البيانات / توافر / مقاومة الفصل (نظرية CAP)
• مخطط بيانات محدد وقيود في قاعدة البيانات أو التخزين لا يتطلب مخطط بيانات
  
• نموذج البيانات - القيمة الرئيسية أو الهرمية أو الرسم البياني أو الوثيقة أو العلائقية
• منطق المعالجة أقرب ما يكون إلى البيانات أو كل معالجة في التطبيق
• تعمل بشكل رئيسي في ذاكرة الوصول العشوائي أو مع نظام فرعي للقرص
• حل شامل أو متخصص
• نستخدم الخبرة الموجودة في قاعدة بيانات ليست مناسبة بشكل خاص لمتطلبات المشروع أو نطور تجربة جديدة في تدريب مناسب ولكن غير مألوف ، "الدم والعرق" (نفس الشيء لا ينطبق على التطوير فحسب ، بل أيضًا على التشغيل)
  
• مدمج أو في عملية / شبكة أخرى
• محب أو رجعي

• لغة الاستعلام "الغريبة"
• واجهة برمجة التطبيقات الأصلية الوحيدة للعمل مع قاعدة البيانات ، الأمر الذي سيعقد الانتقال إلى قواعد البيانات الأخرى (تم إنفاق الوقت وجهد الفريق وميزانية المشروع)
• عدم توفر برامج تشغيل لمنصات / لغات / أنظمة تشغيل أخرى
• نقص رموز المصدر ، أوصاف تنسيق البيانات على القرص (أو حظر التراخيص الهندسية العكسية ، خاصة Oracle مع buggy Coherence)
• نمو تكلفة الترخيص سنة بعد سنة
• النظام البيئي الخاص وصعوبة العثور على المتخصصين
• , ,

QuestDB

• محاولة لتحقيق أقصى استفادة من الأجهزة لأداء الاستعلامات التحليلية - توجيه وظائف التجميع ، والعمل مع البيانات من خلال ملفات الذاكرة المعينة
• SQL كلغة لاستعلامات DML وعمليات DDL لإدارة بنية قاعدة البيانات
• دعم جداول الانضمام الخاصة بالسلسلة الزمنية DB
• دعم وظائف النافذة والتجميع في 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 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);
                }
            }
        }
    }
}

التضمين في تطبيق جافا

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);
            }
        }
    }
}

وحدة تحكم الويب

هل تحتاج إلى قاعدة بيانات أخرى؟