我对KDB不太满意(以免问题听起来很愚蠢)。我正在尝试使用kdb(磁盘而不是内存)从数据库加载我的所有数据。我已经问过有关upsert的问题，我想出了如何从控制台进行upsert并保存到磁盘的方法
q)dsPricing:([id:`int$(); date:`date$()] open:`float$();close:`float$();high:`float$();low:`float$();volume:`int$())
q)dsPricing:([id:`int$(); date:`date$()] open:`float$();close:`float$();high:`float$();low:`float$();volume:`int$())
q)`dsPricing insert(123;2003.03.23;1.0;3.0;4.0;2.0;1000)
q)`dsPricing insert(123;2003.03.24;1.0;3.0;4.0;2.0;2000)
q)save `:dsPricing
q)`:dsPricing upsert(123;2003.03.25;1.0;3.0;4.0;2.0;1500)
现在，我正在尝试使用Java执行此操作，并具有以下代码
public class LoadDS {
SqlSession session;
private DataStreamMapper mapper ;
public static void main(String args[]){
final QConnection q = new QBasicConnection(args.length >= 1 ? args[0] : "localhost", args.length >= 2 ? Integer.parseInt(args[1]) : 5001, "user",
"pwd");
LoadDS l=new LoadDS();
l.session = MyBatisConnectionFactory.getSqlSessionFactory("SMALLS").openSession();
l.mapper = l.session.getMapper(DataStreamMapper.class);
List<DataStream> prices = l.mapper.selectHistoricalPrices(1);
try {
q.open();
q.sync("upsert", "'dsPricing", l.getData(prices));
} catch (QException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// dsPricing:([id:`int$(); date:`date$()] open:`float$();close:`float$();high:`float$();low:`float$();volume:`int$())
private Object[] getData(List<DataStream> prices) {
final Object[] data = new Object[] {new int[prices.size()], new QDate[prices.size()],
new float[prices.size()], new float[prices.size()],
new float[prices.size()],new float[prices.size()],
new int[prices.size()]
};
for ( int i = 0; i < prices.size(); i++ ) {
((int[]) data[0])[i] = prices.get(i).getInfoCode();
((QDate[]) data[1])[i] = new QDate(prices.get(i).getMarketDate());
((float[]) data[2])[i] = (float)prices.get(i).getOpen_();
((float[]) data[3])[i] = (float)prices.get(i).getClose_();
((float[]) data[4])[i] = (float)prices.get(i).getHigh();
((float[]) data[5])[i] = (float)prices.get(i).getLow();
((int[]) data[6])[i] = (int)prices.get(i).getVolume();
}
return data;
}
}
谁能告诉我我在做什么错？数据没有保存，我尝试了多种变体。我宁愿仅从SQL加载数据并将其保存到磁盘以进行初始加载。
最佳答案
您可能想用“dsPricing”或“:dsPricing”代替“'dsPricing”(注意多余的撇号)。 qJava将字符串转换为符号，因此发送“'dsPricing”的方式与通过写'$“'dsPricing”在q中获取的方式一样。