Query data

This page describes how to query data from QuestDB using different programming languages and tools.

For ad-hoc SQL queries, including CSV download and charting use the web console. Applications can choose between the HTTP REST API which returns JSON or use the PostgreSQL wire protocol.

Here are all your options:

• Web Console
  • SQL SELECT statements.
  • Download query results as CSV.
  • Chart query results.
• PostgreSQL wire protocol
  • SQL SELECT statements.
  • Use psql on the command line.
  • Interoperability with third-party tools and libraries.
• HTTP REST API
  • SQL SELECT statements as JSON or CSV.
  • Result paging.

Web Console

QuestDB ships with an embedded Web Console running by default on port 9000.

To query data from the web console, SQL statements can be written in the code editor and executed by clicking the Run button.

Listing tables and querying a table

SHOW TABLES;

SELECT * FROM my_table;

--Note that `SELECT * FROM` is optional

my_table;

Aside from the Code Editor, the Web Console includes a data visualization panel for viewing query results as tables or graphs and an Import tab for uploading datasets as CSV files. For more details on these components and general use of the console, see the Web Console page.

PostgreSQL wire protocol

You can query data using the Postgres endpoint that QuestDB exposes which is accessible by default via port 8812. Examples in multiple languages are shown below. To learn more, check out our docs about Postgres compatibility and tools.

Python

import psycopg2

connection = None

cursor = None

try:

connection = psycopg2.connect(

user='admin',

password='quest',

host='127.0.0.1',

port='8812',

database='qdb')

cursor = connection.cursor()

postgreSQL_select_Query = 'SELECT x FROM long_sequence(5);'

cursor.execute(postgreSQL_select_Query)

print('Selecting rows from test table using cursor.fetchall')

mobile_records = cursor.fetchall()

print("Print each row and it's columns values")

for row in mobile_records:

print("y = ", row[0], "\n")

except (Exception, psycopg2.Error) as error:

print("Error while fetching data from PostgreSQL", error)

finally:

if cursor:

cursor.close()

if connection:

connection.close()

print("PostgreSQL connection is closed")

Java

package com.myco;

import java.sql.*;

import java.util.Properties;

public class App {

public static void main(String[] args) throws SQLException {

Properties properties = new Properties();

properties.setProperty("user", "admin");

properties.setProperty("password", "quest");

properties.setProperty("sslmode", "disable");

final Connection connection = DriverManager.getConnection(

"jdbc:postgresql://localhost:8812/qdb", properties);

try (PreparedStatement preparedStatement = connection.prepareStatement(

"SELECT x FROM long_sequence(5);")) {

try (ResultSet rs = preparedStatement.executeQuery()) {

while (rs.next()) {

System.out.println(rs.getLong(1));

}

}

}

connection.close();

}

}

NodeJS

"use strict"

const { Client } = require("pg")

const start = async () => {

const client = new Client({

database: "qdb",

host: "127.0.0.1",

password: "quest",

port: 8812,

user: "admin",

})

await client.connect()

const res = await client.query("SELECT x FROM long_sequence(5);")

console.log(res.rows)

await client.end()

}

start().catch(console.error)

Go

package main

import (

"database/sql"

"fmt"

_ "github.com/lib/pq"

)

const (

host = "localhost"

port = 8812

user = "admin"

password = "quest"

dbname = "qdb"

)

func main() {

connStr := fmt.Sprintf(

"host=%s port=%d user=%s password=%s dbname=%s sslmode=disable",

host, port, user, password, dbname)

db, err := sql.Open("postgres", connStr)

checkErr(err)

defer db.Close()

// Currently, we do not support queries with bind parameters in Go

rows, err := db.Query("SELECT x FROM long_sequence(5);")

checkErr(err)

defer rows.Close()

for rows.Next() {

var num string

err = rows.Scan(&num)

checkErr(err)

fmt.Println(num)

}

err = rows.Err()

checkErr(err)

}

func checkErr(err error) {

if err != nil {

panic(err)

}

}

C#

// compile with

// g++ libpq_example.c -o libpq_example.exe -I pgsql\include -L dev\pgsql\lib

// -std=c++17 -lpthread -lpq

#include <libpq-fe.h>

#include <stdio.h>

#include <stdlib.h>

void do_exit(PGconn *conn) {

PQfinish(conn);

exit(1);

}

int main() {

PGconn *conn = PQconnectdb(

"host=localhost user=admin password=quest port=8812 dbname=testdb");

if (PQstatus(conn) == CONNECTION_BAD) {

fprintf(stderr, "Connection to database failed: %s\n",

PQerrorMessage(conn));

do_exit(conn);

}

PGresult *res = PQexec(conn, "SELECT x FROM long_sequence(5);");

if (PQresultStatus(res) != PGRES_TUPLES_OK) {

printf("No data retrieved\n");

PQclear(res);

do_exit(conn);

}

int rows = PQntuples(res);

for (int i = 0; i < rows; i++) {

printf("%s\n", PQgetvalue(res, i, 0));

}

PQclear(res);

PQfinish(conn);

return 0;

}

C

using Npgsql;

string username = "admin";

string password = "quest";

string database = "qdb";

int port = 8812;

var connectionString = $@"host=localhost;port={port};username={username};password={password};

database={database};ServerCompatibilityMode=NoTypeLoading;";

await using NpgsqlConnection connection = new NpgsqlConnection(connectionString);

await connection.OpenAsync();

var sql = "SELECT x FROM long_sequence(5);";

await using NpgsqlCommand command = new NpgsqlCommand(sql, connection);

await using (var reader = await command.ExecuteReaderAsync()) {

while (await reader.ReadAsync())

{

var station = reader.GetString(0);

var height = double.Parse(reader.GetString(1));

var timestamp = reader.GetString(2);

}

}

Ruby

require 'pg'

begin

conn =PG.connect( host: "127.0.0.1", port: 8812, dbname: 'qdb',

user: 'admin', password: 'quest' )

rows = conn.exec 'SELECT x FROM long_sequence(5);'

rows.each do |row|

puts row

end

rescue PG::Error => e

puts e.message

ensure

conn.close if conn

end

PHP

<?php

function exceptions_error_handler($severity, $message, $filename, $lineno) {

throw new ErrorException($message, 0, $severity, $filename, $lineno);

}

set_error_handler('exceptions_error_handler');

$db_conn = null;

try {

$db_conn = pg_connect(" host = 'localhost' port=8812 dbname = 'qdb' user = 'admin' password = 'quest' ");

$result = pg_query($db_conn, 'SELECT x FROM long_sequence(5);' );

while ($row = pg_fetch_assoc($result) ){

print_r($row);

}

pg_free_result($result);

} catch (Exception $e) {

echo 'Caught exception: ', $e->getMessage(), "\n";

} finally {

if (!is_null($db_conn)) {

pg_close($db_conn);

}

}

?>

HTTP REST API

QuestDB exposes a REST API for compatibility with a wide range of libraries and tools. The REST API is accessible on port 9000 and has the following query-capable entrypoints:

Entrypoint	HTTP Method	Description	API Docs
/exp?query=..	GET	Export SQL Query as CSV	Reference
/exec?query=..	GET	Run SQL Query returning JSON result set	Reference

For details such as content type, query parameters and more, refer to the REST API docs.

/exp: SQL Query to CSV

The /exp entrypoint allows querying the database with a SQL select query and obtaining the results as CSV.

For obtaining results in JSON, use /exec instead, documented next.

cURL

curl -G --data-urlencode \

"query=SELECT * FROM example_table2 LIMIT 3" \

http://localhost:9000/exp

"col1","col2","col3"

"a",10.5,true

"b",100.0,false

"c",,true

Python

import requests

resp = requests.get(

'http://localhost:9000/exp',

{

'query': 'SELECT * FROM example_table2',

'limit': '3,6' # Rows 3, 4, 5

})

print(resp.text)

"col1","col2","col3"

"d",20.5,true

"e",200.0,false

"f",,true

/exec: SQL Query to JSON

The /exec entrypoint takes a SQL query and returns results as JSON.

This is similar to the /exec entry point which returns results as CSV.

Querying Data

cURL

curl -G \

--data-urlencode "query=SELECT x FROM long_sequence(5);" \

http://localhost:9000/exec

The JSON response contains the original query, a "columns" key with the schema of the results, a "count" number of rows and a "dataset" with the results.

{

"query": "SELECT x FROM long_sequence(5);",

"columns": [

{"name": "x", "type": "LONG"}],

"dataset": [

[1],

[2],

[3],

[4],

[5]],

"count": 5

}

Python

import sys

import requests

host = 'http://localhost:9000'

sql_query = "select * from long_sequence(10)"

try:

response = requests.get(

host + '/exec',

params={'query': sql_query}).json()

for row in response['dataset']:

print(row[0])

except requests.exceptions.RequestException as e:

print(f'Error: {e}', file=sys.stderr)

NodeJS

const fetch = require("node-fetch")

const HOST = "http://localhost:9000"

async function run() {

try {

const query = "SELECT x FROM long_sequence(5);"

const response = await fetch(`${HOST}/exec?query=${encodeURIComponent(query)}`)

const json = await response.json()

console.log(json)

} catch (error) {

console.log(error)

}

}

run()

Go

package main

import (

"fmt"

"io/ioutil"

"log"

"net/http"

"net/url"

)

func main() {

u, err := url.Parse("http://localhost:9000")

checkErr(err)

u.Path += "exec"

params := url.Values{}

params.Add("query", "SELECT x FROM long_sequence(5);")

u.RawQuery = params.Encode()

url := fmt.Sprintf("%v", u)

res, err := http.Get(url)

checkErr(err)

defer res.Body.Close()

body, err := ioutil.ReadAll(res.Body)

checkErr(err)

log.Println(string(body))

}

func checkErr(err error) {

if err != nil {

panic(err)

}

}