java如何实现SQL查询

使用更先进的浏览器访问效果更佳。

java如何实现SQL查询

fightingfy

一条数据记录:

{"TIMES": "{ $timestamp : 2015-01-13-18.30.00.960}",

"APID": 536914828,

"ID": "32841-3",

"V": [

38350,

47,

53,

20,

38350,

153,

47,

]}

其中字段信息：FCN为V.0，CI为V.1，SSRP为V.2，NSRP为V.6

处理的SQL如下：

CREATE TABLE TMP_SRP AS

SELECT ID,TIMES,APID,FCN,CI,

SUM(CASE WHEN SSRP>31 AND NSRP-SSRP>10 THEN 1 ELSE 0 END) MR,

SUM(CASE WHEN SSRP>100 THEN 1 ELSE 0 END) DR

FROM PMO

GROUP BY ID,TIMES,APID,FCN,CI

请问下如何将上面的SQL转换为java代码，或者如何来处理比较好。

Diablo

这个语句估计只有对接pg了。但是现在不确定pg里建外表对到数组后能不能处理sum(v.0)这种操作。

Diablo

我试了一下

create foreign table bar(a int[]) server sdb_server options(collectionspace 'foo', collection 'bar');

然后可以执行查询：

select sum(case when a[1] > 2 then 1 else 0 end ) from bar group by a[1]；

fightingfy

String sql = "select T.OBJECTID,T.TIMES,T.UES1APID,T.OBJ from MRO.P_MROLTE2LTE as T WHERE T.OBJECTID='32997-1' AND T.UES1APID=134254842";

DBCursor cursor = sdb.exec(sql);

System.out.println("打印查询结果1:" + sql);

while (cursor.hasNext()) {

System.out.println(cursor.getNext());

}

String sql1 = "select T.OBJECTID,T.TIMES,T.UES1APID,T.OBJ from MRO.P_MROLTE2LTE as T WHERE T.OBJECTID='32997-1' AND T.UES1APID=134254842 AND T.UES1APID=134254842 AND T.OBJ[0][1]=19";

DBCursor cursor1 = sdb.exec(sql1);

System.out.println("打印查询结果2:" + sql1);

while (cursor1.hasNext()) {

System.out.println(cursor1.getNext());

}

====》第一个语句能输出下面数据，但是第二个语句查询无结果。请问下应该如何对数组中的数据进行过滤。

其实我是想将OBJ中的每个数组中的第二个值为19的数据都查询出来。

{ "TIMES" : "{ $timestamp : 2015-01-13-17.56.33.920}" , "UES1APID" : 134254842 , "OBJECTID" : "32997-1" , "OBJ" : [ [ 38350 , 19 , 48 , 16 , 38350 , 78 , 43 , 5] , [ 38350 , 19 , 48 , 16 , 38350 , 173 , 39 , 0]]}

{ "TIMES" : "{ $timestamp : 2015-01-13-17.56.39.40}" , "UES1APID" : 134254842 , "OBJECTID" : "32997-1" , "OBJ" : [ [ 38350 , 19 , 51 , 18 , 38950 , 286 , 17 , 3] , [ 38350 , 19 , 51 , 18 , 38950 , 447 , 17 , 5] , [ 38350 , 19 , 51 , 18 , 38950 , 441 , 17 , 5] , [ 38350 , 19 , 51 , 18 , 38350 , 20 , 47 , 9] , [ 38350 , 19 , 51 , 18 , 38350 , 78 , 46 , 6]]}

{ "TIMES" : "{ $timestamp : 2015-01-13-17.56.44.160}" , "UES1APID" : 134254842 , "OBJECTID" : "32997-1" , "OBJ" : [ [ 38350 , 19 , 53 , 20 , 37900 , 232 , 36 , 13] , [ 38350 , 19 , 53 , 20 , 37900 , 234 , 32 , 5] , [ 38350 , 19 , 53 , 20 , 38950 , 441 , 18 , 7] , [ 38350 , 19 , 53 , 20 , 38950 , 477 , 18 , 9] , [ 38350 , 19 , 53 , 20 , 38950 , 286 , 16 , 4] , [ 38350 , 19 , 53 , 20 , 38100 , 233 , 37 , 23]]}

Diablo

这里有个概念说明一下。上面所给出的例子是基于pg对接sdb的。你使用的exec不是pg，只是内部实现的一个接口。如果希望使用SQL强烈推荐对接pg。具体可以看信息中心里的第三方对接。

针对第二个语句改写SQL:

select T.OBJECTID,T.TIMES,T.UES1APID,T.OBJ from MRO.P_MROLTE2LTE as T WHERE T.OBJECTID='32997-1' AND T.UES1APID=134254842 AND T.UES1APID=134254842 AND T.OBJ.0.1=19"

fightingfy

好的，我试试对接PG

Diablo

ps：我上面说的改写是针对exec的。

fightingfy

foo=# create foreign table P_MROLTE2LTE(CITY VARCHAR(20),TIMES TIMESTAMP,VENDOR VARCHAR(2),SITEID INT,ECODE INT,GROUPID NUMERIC(10),UES1APID NUMERIC(15),OBJECTID VARCHAR(10),OBJ INT[][]) server sdb_server options(collectionspace 'MRO',collection 'P_MROLTE2

LTE');

CREATE FOREIGN TABLE

foo=# SELECT COUNT(*) FROM P_MROLTE2LTE;

count

---------

3693005

(1 row)

foo=#

foo=# SELECT * FROM P_MROLTE2LTE LIMIT 2;

------+-------+--------+--------+-------+---------+----------+----------+-----

| | | | | | | |

(2 rows)

foo=# SELECT * FROM P_MROLTE2LTE LIMIT 2 OFFSET 4;

------+-------+--------+--------+-------+---------+----------+----------+-----

| | | | | | | |

请问下，上面的内容什么回事？绑定sequoiadb的集合后，能查询出记录数，但是显示数据的时候，则值是空白的。

linyoubin

1. 字段名不一致

2. 字段名大小写敏感，大写字段名需要使用双引号，具体可见使用文档2.2.2

http://www.sequoiadb.com/cn/index.php?p=whitepaper_7

3. 字段类型不匹配

fightingfy

LTE');

db.MRO.P_MROLTE2LTE.find().limit(1)

{

"_id": {

"$oid": "557a65881192c76c5b000000"

"CITY": "GUANGZHOU",

"TIMES": "{ $timestamp : 2015-01-13-18.30.00.960}",

"VENDOR": "HUAWEI",

"SITEID": 32841,

"ECODE": 72,

"GROUPID": 1094,

"UES1APID": 536903297,

"OBJECTID": "32841-3",

"OBJ": [

[

38350,

47,

67,

24,

37900,

252,

44,

Foreign table "public.p_mrolte2lte"

Column | Type | Modifiers | FDW Options

----------+-----------------------------+-----------+-------------

city | character varying(20) | |

times | timestamp without time zone | |

vendor | character varying(2) | |

siteid | integer | |

ecode | integer | |

groupid | numeric(10,0) | |

ues1apid | numeric(15,0) | |

objectid | character varying(10) | |

obj | integer[] | |

Server: sdb_server

FDW Options: (collectionspace 'MRO', collection 'P_MROLTE2LTE')

唯一不同时创建表时字段OBJ的时候是二维，\d表时时看到的类型是一维

Diablo

多维的以前还真没试过，我们要看一下是pg的问题还是对接的问题。

fightingfy

二维数组部分改造成一维数组，查询结果能看到数据了。其实我本身是想通过二维数据减少入库的数据。

目前也不太清楚sequoiadb对二维数组的查询性能和一维数组或者全是BasicBSONObject类型相比是否有重大差距。这点求指教。

foo=# create foreign table P_MROLTE2LTE("CITY" VARCHAR(20),"TIMES" TIMESTAMP,"VENDOR" VARCHAR(20),"SITEID" INT,"ECODE" INT,"GROUPID" NUMERIC(10)

,"UES1APID" NUMERIC(15),"OBJECTID" VARCHAR(10),"V" INT[]) server sdb_server options(collectionspace 'MRO',collection 'P_MROLTE2LTE');

CREATE FOREIGN TABLE

foo=# \d P_MROLTE2LTE

Foreign table "public.p_mrolte2lte"

Column | Type | Modifiers | FDW Options

----------+-----------------------------+-----------+-------------

CITY | character varying(20) | |

TIMES | timestamp without time zone | |

VENDOR | character varying(20) | |

SITEID | integer | |

ECODE | integer | |

GROUPID | numeric(10,0) | |

UES1APID | numeric(15,0) | |

OBJECTID | character varying(10) | |

V | integer[] | |

foo=# select * from P_MROLTE2LTE LIMIT 3;

-----------+-------+--------+--------+-------+---------+-----------+----------+----------------------------------

GUANGZHOU | | HUAWEI | 32841 | 72 | 1094 | 536903297 | 32841-3 | {38350,47,67,24,37900,252,44,12}

GUANGZHOU | | HUAWEI | 32841 | 72 | 1094 | 536903297 | 32841-3 | {38350,47,67,24,37900,253,43,11}

GUANGZHOU | | HUAWEI | 32841 | 72 | 1094 | 536903297 | 32841-3 | {38350,47,67,24,37900,242,43,9}

(3 rows)

timestamp这个字段的值没有显示不出来。

Diablo

1. 关于多维数组性能问题能不能给个例子，没有明白LZ的意思。

2. sdb中TIMES字段的类型也是timestamp的吗？用db.foo.bar.insert({TIMES:Timestamp()})构造数据试试看。

fightingfy

对于第一点，是想问下二维数组和一维数据在查询性能上是否有较大差异。

> db.MRO.P_MROLTE2LTE.count()

12678346

Takes 0.429s.

> db.MRO.P_MROLTE2LTE.insert({"TIMES":Timestamp()})

Takes 0.782s.

> db.MRO.P_MROLTE2LTE.count()

12678347

Takes 0.438s.

Diablo

1. 嵌套越复杂肯定越慢，而且代码处理逻辑也会变复杂。不过最大的瓶颈还是在IO。

2. 这俩count是啥意思,? 你pg里timestamp无法显示，有可能是和sdb的数据类型对不上造成的。我的意思是你

用db.foo.bar.insert({TIMES:Timestamp()})在sdb里构造数据，这样sdb里TIMES就是timestamp类型，然后用pg建外表查一下看能不能显示出来。

fightingfy

之前将BSONTimestamp先toString()后再塞入到BasicBSONObject对象时，生成的字符串格式入库之后并非是timestamp数据类型，而是字符串类型。所以在PG对接的表中查询不出timestamp的数据。timestamp的字符串格式转换还需要另处理下才行，生成数据入图左边信息。但是入库之后出现两个有疑问的地方。请看同样也是框中的部分。

Diablo

用左边的问题件做导入吗，能不能把这个文件穿传上来。

fightingfy

另外请教一下

foo=# create table tests1 AS select * from P_MROLTE2LTE LIMIT 3;

在PG中以上述方式创建的表，应该怎样也随pg创建后自动在sequoiadb中创建。

Diablo

.960这个地方并不是小数的意思，而是一种格式而已。所以18.30.00.960代表是在微秒部分补正960, 转过去以后就变成000960了。

Diablo

自动建表貌似做不了吧。至少我不知道怎么做。