Trafodion 처리 JSON 반구 조화 데이터

Trafodion 은 구조 화 된 데 이 터 를 처리 할 수 있 을 뿐만 아니 라 반구 조 화 된 데이터 및 비구 조 화 된 데 이 터 를 처리 할 수 있 으 며 반구 조 화 된 데이터 와 비구 조 화 된 데 이 터 는 주로 TMUDF 기능 을 사용한다.본 고 는 실제 사례 를 통 해 어떻게 TMUDF 를 사용자 정의 하여 JSON 형식 텍스트 를 분석 하여 반구 조 화 된 데 이 터 를 처리 하 는 지 상세 하 게 설명 하고 자 한다.
1 JAVA 클래스 를 작성 하여 JSON 텍스트 를 해석 합 니 다. 참고 하 십시오.https://github.com/esgyn/code-examples/blob/master/src/main/java/org/trafodion/examples/udrs/udfs/table_valued/json_columnizer/json_columnizer. java 구체 적 인 용법 상기 코드 는 다음 과 같이 언급 되 었 습 니 다.

/* ===================================================================================
     *
     * This is a Table Mapping UDF for Trafodion
     *
     * Input table contains a single VARCHAR/STRING column that is a complete JSON record
     * UDF outputs values corresponding to JSON tags passed in the calling statement
     * A variable number of tags can be passed in
     *
     * Tag names must be fully qualified, eg, 'Master.Employee.Middle Initial' for JSON
     *  {"MASTER": {"EMPLOYEE": { "Middle Initial": "Q" } } } 
     *
     *
     * To invoke this UDF:
     * 
     *     select * from udf(json_column(table( select * from  ),
     *                                         '', '', ...) );
     *                                         
     * =================================================================================== */

2 JAR 패키지 json 컴 파일 및 생 성columnizer. jar (메모: javax. json - 1.0.4. jar 를 함께 포장 해 야 합 니 다)

[root@cent-2 udr]# ll json_columnizer.jar
-rw-rw-r--. 1 centos centos 380574 Feb  7 11:47 json_columnizer.jar
[root@cent-2 udr]# pwd
/home/trafodion/esgynDB-2.2.0/udr

3 라 이브 러 리 및 Table 만 들 기Mapping Function

create library trafodion.seabase.json_columnizer file '/home/trafodion/esgynDB-2.2.0/udr/json_columnizer.jar';

create table_mapping function trafodion.seabase.unjson_obj
(
)
EXTERNAL NAME 'json_columnizer'
LIBRARY trafodion.seabase.json_columnizer
LANGUAGE JAVA
NO SQL;

4 샘플 JSON 텍스트 준비

{
  "firstName": "John",
  "lastName": "Smith",
  "isAlive": true,
  "age": 25,
  "address": {
    "streetAddress": "21 2nd Street",
    "city": "New York",
    "state": "NY",
    "postalCode": "10021-3100"
  },
  "phoneNumbers": [
    {
      "type": "home",
      "number": "212 555-1234"
    },
    {
      "type": "office",
      "number": "646 555-4567"
    },
    {
      "type": "mobile",
      "number": "123 456-7890"
    }
  ],
  "children": [],
  "spouse": null
}

5. 테스트 표를 만 들 고 JSON 문자열 을 삽입 합 니 다.

SQL>create table json_test ( jsondata varchar(2000));
SQL>insert into json_test values('{"firstName":"John","lastName":"Smith","isAlive":true,"age":25,"address":{"streetAddress":"212ndStreet","city":"NewYork","state":"NY","postalCode":"10021-3100"},"phoneNumbers":[{"type":"home","number":"212555-1234"},{"type":"office","number":"646555-4567"},{"type":"mobile","number":"123456-7890"}],"children":[],"spouse":null}');

6. 분석 한 JSON 문자열 조회

SQL>select * from udf(trafodion.seabase.unjson_obj(table(select jsondata from trafodion.seabase.json_test),'firstName','lastName'));

FIRSTNAME                                                                                            LASTNAME                                                                                           
---------------------------------------------------------------------------------------------------- ----------------------------------------------------------------------------------------------------
John                                                                                                 Smith                                                                                              

--- 1 row(s) selected.