使用 JDBC 在 KDB 数据库中执行查询答案

【问题标题】：Executing queries in KDB database using JDBC使用 JDBC 在 KDB 数据库中执行查询
【发布时间】：2016-04-09 06:28:18
【问题描述】：

我可以执行以下代码从表中选择所有数据：-

package com.jdbc;
import java.sql.*;
//in kdb+3.x and above
//init table with
//\p 5001
//Employees:([]id:0 1 2;firstName:`Charlie`Arthur`Simon;lastName:`Skelton`Whitney`Garland;age:10 20 30;timestamp:.z.p+til 3)
public class Selection{

  static final String JDBC_DRIVER="jdbc";
  static final String DB_URL="jdbc:q:localhost:5001";
  static final String USER="";
  static final String PASS="";
  public static void main(String[] args){
    Connection conn=null;
    Statement stmt=null;
    try{
      Class.forName(JDBC_DRIVER);
      System.out.println("Connecting to database...");
      conn=DriverManager.getConnection(DB_URL,USER,PASS);
      System.out.println("Creating statement...");
      stmt=conn.createStatement();
      ResultSet rs=stmt.executeQuery("SELECT id, firstName, lastName, age,timestamp FROM Employees");
      while(rs.next()){
        long id=rs.getLong("id");
        long age=rs.getLong("age");
        String first=rs.getString("firstName");
        String last=rs.getString("lastName");
        Timestamp timestamp=rs.getTimestamp("timestamp");
        System.out.print("ID: "+id);
        System.out.print(", Age: "+age);
        System.out.print(", FirstName: "+first);
        System.out.println(", LastName: "+last);
        System.out.println(", Timestamp: "+timestamp);
      }
      rs.close();
      stmt.close();
      conn.close();
    }catch(SQLException se){
      se.printStackTrace();
    }catch(Exception e){
      e.printStackTrace();
    }finally{
      try{
        if(stmt!=null)
          stmt.close();
      }catch(SQLException se2){
      }
      try{
        if(conn!=null)
          conn.close();
      }catch(SQLException se){
        se.printStackTrace();
      }
    }
  }
}

但是每当我尝试运行其他查询时，代码都会给我错误，例如，对于以下代码：-

package com.jdbc;
import java.sql.*;

//in kdb+3.x and above
//init table with
//\p 5001
//Employees:([]id:0 1 2;firstName:`Charlie`Arthur`Simon;lastName:`Skelton`Whitney`Garland;age:10 20 30;timestamp:.z.p+til 3)

public class Insertion {

  static final String JDBC_DRIVER="jdbc";
  static final String DB_URL="jdbc:q:localhost:5001";
  static final String USER="";
  static final String PASS="";

  public static void main(String[] args){
    Connection conn=null;
    Statement stmt=null;
    try{
      Class.forName(JDBC_DRIVER);

      System.out.println("Connecting to database...");
      conn=DriverManager.getConnection(DB_URL,USER,PASS);

      System.out.println("Creating statement...");
      stmt=conn.createStatement();
      stmt.executeUpdate("INSERT INTO Employees VALUES(9, 10, 'X', 'Y', " + new java.sql.Timestamp(0) + ")");

      stmt.close();
      conn.close();
    }catch(SQLException se){
      se.printStackTrace();
    }catch(Exception e){
      e.printStackTrace();
    }finally{
      try{
        if(stmt!=null)
          stmt.close();
      }catch(SQLException se2){
      }
      try{
        if(conn!=null)
          conn.close();
      }catch(SQLException se){
        se.printStackTrace();
      }
    }
  }
}

对于此代码，我收到以下错误：-

正在连接数据库...正在创建语句... java.sql.SQLException: 在 jdbc.q(jdbc.java:22) 在 jdbc$co.ex(jdbc.java:26) 在 jdbc$st.executeUpdate(jdbc.java:89) 在 com.jdbc.Insertion.main(Insertion.java:27)

当我尝试使用聚合函数进行选择查询时，我经常会遇到类似的错误。总而言之，我只能做简单的数据选择。

有什么线索吗？

是否有任何研究；关于如何使用 JDBC 对 KDB 数据库进行复杂查询的链接？

我也尝试过使用准备好的语句（代码如下），但仍然没有运气：-

package com.jdbc;
import java.sql.*;

//in kdb+3.x and above
//init table with
//\p 5001
//Employees:([]id:0 1 2;firstName:`Charlie`Arthur`Simon;lastName:`Skelton`Whitney`Garland;age:10 20 30;timestamp:.z.p+til 3)

public class Insertion {

  static final String JDBC_DRIVER="jdbc";
  static final String DB_URL="jdbc:q:localhost:5001";
  static final String USER="";
  static final String PASS="";

  public static void main(String[] args){
    Connection conn=null;
    PreparedStatement stmt=null;
    try{
      Class.forName(JDBC_DRIVER);

      System.out.println("Connecting to database...");
      conn=DriverManager.getConnection(DB_URL,USER,PASS);

      System.out.println("Creating statement...");
      stmt=conn.prepareStatement("INSERT INTO Employees(id,firstName,lastName,age,timestamp) VALUES(?, ?, ?, ?, ?)");
  stmt.setInt(1, 10);
  stmt.setString(2, "X");
  stmt.setString(3, "Y");
  stmt.setInt(4, 5);
  stmt.setTimestamp(5, new Timestamp(0));
      stmt.executeUpdate();

      stmt.close();
      conn.close();
    }catch(SQLException se){
      se.printStackTrace();
    }catch(Exception e){
      e.printStackTrace();
    }finally{
      try{
        if(stmt!=null)
          stmt.close();
      }catch(SQLException se2){
      }
      try{
        if(conn!=null)
          conn.close();
      }catch(SQLException se){
        se.printStackTrace();
      }
    }
  }
}

【问题讨论】：

使用准备好的语句：docs.oracle.com/javase/tutorial/jdbc/basics/prepared.html
我也用过，还是遇到同样的错误。
更新了帖子以包含代码。
糟糕，我的错。我已经更新了更正的代码。我也尝试过执行，但错误仍然相同。
这是完整的堆栈跟踪。

标签： java sql database jdbc kdb

【解决方案1】：

尝试使用原生 API 而不是 JDBC。

【讨论】：

【解决方案2】：

我一直在努力解决同样的 INSERT 问题。纯属偶然，发现如果将 'VALUES' 更改为小写的 'values' ，则 static INSERT 语句开始工作。尽管如此，PreparedStatement 执行仍然没有运气。（就我而言，不幸的是，不能使用原生 API。）

【讨论】：