Mercurial > hg > monetdb-java
view tests/Test_PSsqldata.java @ 0:a5a898f6886c
Copy of MonetDB java directory changeset e6e32756ad31.
author | Sjoerd Mullender <sjoerd@acm.org> |
---|---|
date | Wed, 21 Sep 2016 09:34:48 +0200 (2016-09-21) |
parents | |
children | 04fbf3655452 |
line wrap: on
line source
/* * This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at http://mozilla.org/MPL/2.0/. * * Copyright 1997 - July 2008 CWI, August 2008 - 2016 MonetDB B.V. */ import java.sql.*; import nl.cwi.monetdb.jdbc.types.*; public class Test_PSsqldata { public static void main(String[] args) throws Exception { Class.forName("nl.cwi.monetdb.jdbc.MonetDriver"); Connection con = DriverManager.getConnection(args[0]); Statement stmt = con.createStatement(); PreparedStatement pstmt; ResultSet rs = null; ResultSetMetaData rsmd = null; ParameterMetaData pmd = null; con.setAutoCommit(false); // >> false: auto commit should be off now System.out.println("0. false\t" + con.getAutoCommit()); try { stmt.executeUpdate("CREATE TABLE table_Test_PSsqldata ( myinet inet, myurl url )"); pstmt = con.prepareStatement("INSERT INTO table_Test_PSsqldata VALUES (?, ?)"); pmd = pstmt.getParameterMetaData(); System.out.println("1. 2 parameters:\t" + pmd.getParameterCount()); for (int col = 1; col <= pmd.getParameterCount(); col++) { System.out.println("" + col + "."); System.out.println("\ttype " + pmd.getParameterType(col)); System.out.println("\ttypename " + pmd.getParameterTypeName(col)); System.out.println("\tclassname " + pmd.getParameterClassName(col)); } INET tinet = new INET(); URL turl = new URL(); tinet.fromString("172.5.5.5/24"); turl.fromString("http://www.monetdb.org/"); pstmt.setObject(1, tinet); pstmt.setObject(2, turl); pstmt.execute(); tinet.setNetmaskBits(16); pstmt.execute(); rs = stmt.executeQuery("SELECT * FROM table_Test_PSsqldata"); rsmd = rs.getMetaData(); for (int i = 1; rs.next(); i++) { for (int col = 1; col <= rsmd.getColumnCount(); col++) { Object x = rs.getObject(col); if (x == null) { System.out.println("" + i + ".\t<null>"); } else { System.out.println("" + i + ".\t" + x.toString()); if (x instanceof INET) { INET inet = (INET)x; System.out.println("\t" + inet.getAddress() + "/" + inet.getNetmaskBits()); System.out.println("\t" + inet.getInetAddress().toString()); } else if (x instanceof URL) { URL url = (URL)x; System.out.println("\t" + url.getURL().toString()); } } } } } catch (SQLException e) { System.out.println("failed :( "+ e.getMessage()); System.out.println("ABORTING TEST!!!"); } con.rollback(); con.close(); } }