JDBC 드라이버 연결

tibero[DB_MAJOR_VERSION]-jdbc-[JDK_VERSION]-[DEBUG].jar

java -jar [driver_name]

$ java -jar tibero7-jdbc.jar

Tibero JDBC Driver 7.0 (develop) (Rev.1e6bd49823)

Copyright 2020 TmaxTibero Co., Ltd. All Rights Reserved.

Patch files (none)

jdbc:tibero:thin:@<ip>:<port>:<db_name>

jdbc:tibero:thin:@192.168.17.24:7777:tibero

jdbc:tibero:thin:@(description=
    (failover=on)(load_balance=on)
    (address_list=(address=(host=<node1_ip>)(port=<node1_port>))
                  (address=(host=<node2_ip>)(port=<node2_port>))
    )(DATABASE_NAME=<db_name>))

jdbc:tibero:thin:@(description=
    (failover=on)(load_balance=on)
    (address_list=(address=(host=192.168.17.24)(port=10010))
                  (address=(host=192.168.17.24)(port=10020))
    )(DATABASE_NAME=<db_name>))

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.tmax.tibero.jdbc.ext.TbDataSource;

public class TiberoJDBC {

    public static void main(String[] args) throws SQLException { 
    
        TbDataSource tds = new TbDataSource();
        tds.setURL("jdbc:tibero:thin:@127.0.0.1:8629:t5");
        tds.setUser("dbtech");
        tds.setPassword("dbtech");
        
        Connection conn = tds.getConnection();
        Statement stmt = conn.createStatement();
        
        String query = "select table_name from user_tables where rownum < 10 " ; 
        ResultSet rs = stmt.executeQuery(query);

        String sTname=null; 
       
        int irows = 1;
        while ( rs.next() ) {
            sTname = rs.getString("table_name");
            System.out.println("row[" + irows + "] : " + sTname); 
            irows++;
        }
        rs.close(); 
        stmt.close(); 
        conn.close(); 
     }
}

ds = (DataSource)ctx.lookup("tibero"); 
conn = ds.getConnection();

ins_pstmt = (TbPreparedStatement)conn.prepareStatement(ins_query);
ins_pstmt.setString(1, "test");
ins_pstmt.setNString(2, "multinational character");

CREATE OR REPLACE PACKAGE TYPE_PKG
AS
    TYPE "TY_CHOICE_IDX_ARR" IS VARRAY(20000) OF CLOB; 
END;
/
CREATE OR REPLACE PROCEDURE TB_ARRAY_TEST 
(
  I_INPT_EXPC_DIV IN VARCHAR2,
  ....
  O_CHOICE_PACKET OUT TYPE_PKG.TY_CHOICE_IDX_ARR /* TYPE */ 
)
IS
  .....
  L_DATA TYPE_PKG.TY_CHOICE_IDX_ARR; 
  TMP_CLOB_RTN CLOB;
  BEGIN 
  -- init
  L_DATA := TYPE_PKG.TY_CHOICE_IDX_ARR(); 
  TYPE AAA_SET IS TABLE OF CBT_CAT%ROWTYPE; 
  AAA AAA_SET;
....
  FOR I IN AAA.FIRST .. AAA.LAST 
  LOOP
     -- CLOB return function
     T_CHOICE_IDX_LIST := FN_CHOICE_LIST_ADD_01();
     O_CHOICE_IDX_LIST := O_CHOICE_IDX_LIST || T_DELIM_PIPE || T_CHOICE_IDX_LIST; 
  END LOOP;
  L_DATA.EXTEND;
  L_DATA(L_DATA.COUNT) := O_CHOICE_IDX_LIST || 'FALSE' || 'string test' 
  O_CHOICE_PACKET := L_DATA;
END; 
/

CallableStatement cstmt = null; 
Array packetArray = null;

callableSql = "begin ? :=TB_ARRAY_TEST(?,?,?,?,?); end;"; 

try{
   cstmt = (CallableStatement)con.prepareCall(callableSql);
   cstmt.setString(1, domainCd.trim());
   cstmt.setString(2, tsNo.trim());
   cstmt.setDouble(3, Double.parseDouble(verNo.trim()));
   cstmt.setString(4, inptExpcDiv);
   cstmt.setString (5, choiceGrpNo);
   //out parameter
   cstmt.registerOutParameter(6, TbTypes.ARRAY, "TYPE_PKG.TY_CHOICE_IDX_ARR" ); 
   cstmt.execute();
   packetArray = cstmt.getArray(6); 

   // Get the ARRAY object
     if(packetArray == null){
       throw new BCException("no data"); 
     }
     Object o = packetArray.getArray();
     clobs = (Clob[])o;
     choiceGrpPacketList = new ArrayList(clobs.length); 
     Clob clob = null;
     String packet = null; 
     long clobLength = 0;
     for( int i = 0 ; i < clobs.length; i++ ){ 
       clob = clobs[i];
       clobLength = clob.length();
       packet = clob.getSubString(1, (int)clobLength);
       choiceGrpPacketList.add(JdbcCodeConvertor.toKor(packet)); 
     }
   }catch(SQLException sqle){ 
     sqle.printStackTrace();
   }finally{
     if( cstmt != null ){ 
       try{
         cstmt.close();
       }catch(SQLException sqle) {
         logger.error("CallableStatement close Error !"); 
         sqle.printStackTrace();
       } 
     }
}