Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveCallableStatement.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveCallableStatement.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveCallableStatement.java (working copy) @@ -56,7 +56,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getArray(int) */ @@ -67,7 +67,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getArray(java.lang.String) */ @@ -78,7 +78,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBigDecimal(int) */ @@ -89,7 +89,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBigDecimal(java.lang.String) */ @@ -100,7 +100,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBigDecimal(int, int) */ @@ -111,7 +111,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBlob(int) */ @@ -122,7 +122,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBlob(java.lang.String) */ @@ -133,7 +133,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBoolean(int) */ @@ -144,7 +144,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBoolean(java.lang.String) */ @@ -155,7 +155,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getByte(int) */ @@ -166,7 +166,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getByte(java.lang.String) */ @@ -177,7 +177,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBytes(int) */ @@ -188,7 +188,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getBytes(java.lang.String) */ @@ -199,7 +199,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getCharacterStream(int) */ @@ -210,7 +210,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getCharacterStream(java.lang.String) */ @@ -221,7 +221,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getClob(int) */ @@ -232,7 +232,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getClob(java.lang.String) */ @@ -243,7 +243,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getDate(int) */ @@ -254,7 +254,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getDate(java.lang.String) */ @@ -265,7 +265,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getDate(int, java.util.Calendar) */ @@ -276,7 +276,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getDate(java.lang.String, * java.util.Calendar) */ @@ -288,7 +288,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getDouble(int) */ @@ -299,7 +299,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getDouble(java.lang.String) */ @@ -310,7 +310,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getFloat(int) */ @@ -321,7 +321,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getFloat(java.lang.String) */ @@ -332,7 +332,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getInt(int) */ @@ -343,7 +343,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getInt(java.lang.String) */ @@ -354,7 +354,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getLong(int) */ @@ -365,7 +365,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getLong(java.lang.String) */ @@ -376,7 +376,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getNCharacterStream(int) */ @@ -387,7 +387,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getNCharacterStream(java.lang.String) */ @@ -398,7 +398,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getNClob(int) */ @@ -409,7 +409,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getNClob(java.lang.String) */ @@ -420,7 +420,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getNString(int) */ @@ -431,7 +431,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getNString(java.lang.String) */ @@ -442,7 +442,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getObject(int) */ @@ -453,7 +453,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getObject(java.lang.String) */ @@ -464,7 +464,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getObject(int, java.util.Map) */ @@ -475,7 +475,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getObject(java.lang.String, java.util.Map) */ @@ -486,7 +486,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getRef(int) */ @@ -497,7 +497,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getRef(java.lang.String) */ @@ -508,7 +508,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getRowId(int) */ @@ -519,7 +519,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getRowId(java.lang.String) */ @@ -530,7 +530,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getSQLXML(int) */ @@ -541,7 +541,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getSQLXML(java.lang.String) */ @@ -552,7 +552,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getShort(int) */ @@ -563,7 +563,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getShort(java.lang.String) */ @@ -574,7 +574,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getString(int) */ @@ -585,7 +585,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getString(java.lang.String) */ @@ -596,7 +596,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTime(int) */ @@ -607,7 +607,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTime(java.lang.String) */ @@ -618,7 +618,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTime(int, java.util.Calendar) */ @@ -629,7 +629,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTime(java.lang.String, * java.util.Calendar) */ @@ -641,7 +641,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTimestamp(int) */ @@ -652,7 +652,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTimestamp(java.lang.String) */ @@ -663,7 +663,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTimestamp(int, java.util.Calendar) */ @@ -674,7 +674,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getTimestamp(java.lang.String, * java.util.Calendar) */ @@ -686,7 +686,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getURL(int) */ @@ -697,7 +697,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#getURL(java.lang.String) */ @@ -708,7 +708,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#registerOutParameter(int, int) */ @@ -719,7 +719,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#registerOutParameter(java.lang.String, int) */ @@ -730,7 +730,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#registerOutParameter(int, int, int) */ @@ -742,7 +742,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#registerOutParameter(int, int, * java.lang.String) */ @@ -755,7 +755,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#registerOutParameter(java.lang.String, int, * int) */ @@ -768,7 +768,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#registerOutParameter(java.lang.String, int, * java.lang.String) */ @@ -781,7 +781,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setAsciiStream(java.lang.String, * java.io.InputStream) */ @@ -794,7 +794,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setAsciiStream(java.lang.String, * java.io.InputStream, int) */ @@ -807,7 +807,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setAsciiStream(java.lang.String, * java.io.InputStream, long) */ @@ -820,7 +820,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBigDecimal(java.lang.String, * java.math.BigDecimal) */ @@ -833,7 +833,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBinaryStream(java.lang.String, * java.io.InputStream) */ @@ -846,7 +846,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBinaryStream(java.lang.String, * java.io.InputStream, int) */ @@ -859,7 +859,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBinaryStream(java.lang.String, * java.io.InputStream, long) */ @@ -872,7 +872,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBlob(java.lang.String, java.sql.Blob) */ @@ -883,7 +883,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBlob(java.lang.String, * java.io.InputStream) */ @@ -896,7 +896,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBlob(java.lang.String, * java.io.InputStream, long) */ @@ -909,7 +909,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBoolean(java.lang.String, boolean) */ @@ -920,7 +920,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setByte(java.lang.String, byte) */ @@ -931,7 +931,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setBytes(java.lang.String, byte[]) */ @@ -942,7 +942,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setCharacterStream(java.lang.String, * java.io.Reader) */ @@ -955,7 +955,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setCharacterStream(java.lang.String, * java.io.Reader, int) */ @@ -968,7 +968,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setCharacterStream(java.lang.String, * java.io.Reader, long) */ @@ -981,7 +981,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setClob(java.lang.String, java.sql.Clob) */ @@ -992,7 +992,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setClob(java.lang.String, java.io.Reader) */ @@ -1003,7 +1003,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setClob(java.lang.String, java.io.Reader, * long) */ @@ -1016,7 +1016,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setDate(java.lang.String, java.sql.Date) */ @@ -1027,7 +1027,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setDate(java.lang.String, java.sql.Date, * java.util.Calendar) */ @@ -1040,7 +1040,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setDouble(java.lang.String, double) */ @@ -1051,7 +1051,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setFloat(java.lang.String, float) */ @@ -1062,7 +1062,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setInt(java.lang.String, int) */ @@ -1073,7 +1073,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setLong(java.lang.String, long) */ @@ -1084,7 +1084,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNCharacterStream(java.lang.String, * java.io.Reader) */ @@ -1097,7 +1097,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNCharacterStream(java.lang.String, * java.io.Reader, long) */ @@ -1110,7 +1110,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNClob(java.lang.String, java.sql.NClob) */ @@ -1121,7 +1121,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNClob(java.lang.String, java.io.Reader) */ @@ -1132,7 +1132,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNClob(java.lang.String, java.io.Reader, * long) */ @@ -1145,7 +1145,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNString(java.lang.String, * java.lang.String) */ @@ -1158,7 +1158,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNull(java.lang.String, int) */ @@ -1169,7 +1169,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setNull(java.lang.String, int, * java.lang.String) */ @@ -1182,7 +1182,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setObject(java.lang.String, * java.lang.Object) */ @@ -1194,7 +1194,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setObject(java.lang.String, * java.lang.Object, int) */ @@ -1207,7 +1207,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setObject(java.lang.String, * java.lang.Object, int, int) */ @@ -1220,7 +1220,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setRowId(java.lang.String, java.sql.RowId) */ @@ -1231,7 +1231,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setSQLXML(java.lang.String, * java.sql.SQLXML) */ @@ -1244,7 +1244,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setShort(java.lang.String, short) */ @@ -1255,7 +1255,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setString(java.lang.String, * java.lang.String) */ @@ -1267,7 +1267,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setTime(java.lang.String, java.sql.Time) */ @@ -1278,7 +1278,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setTime(java.lang.String, java.sql.Time, * java.util.Calendar) */ @@ -1291,7 +1291,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setTimestamp(java.lang.String, * java.sql.Timestamp) */ @@ -1304,7 +1304,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setTimestamp(java.lang.String, * java.sql.Timestamp, java.util.Calendar) */ @@ -1317,7 +1317,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#setURL(java.lang.String, java.net.URL) */ @@ -1328,7 +1328,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.CallableStatement#wasNull() */ @@ -1339,7 +1339,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#addBatch() */ @@ -1350,7 +1350,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#clearParameters() */ @@ -1361,7 +1361,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#execute() */ @@ -1372,7 +1372,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#executeQuery() */ @@ -1383,7 +1383,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#executeUpdate() */ @@ -1394,7 +1394,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#getMetaData() */ @@ -1405,7 +1405,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#getParameterMetaData() */ @@ -1416,7 +1416,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setArray(int, java.sql.Array) */ @@ -1427,7 +1427,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setAsciiStream(int, java.io.InputStream) */ @@ -1438,7 +1438,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setAsciiStream(int, java.io.InputStream, * int) */ @@ -1451,7 +1451,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setAsciiStream(int, java.io.InputStream, * long) */ @@ -1464,7 +1464,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBigDecimal(int, java.math.BigDecimal) */ @@ -1476,7 +1476,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBinaryStream(int, java.io.InputStream) */ @@ -1488,7 +1488,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBinaryStream(int, java.io.InputStream, * int) */ @@ -1501,7 +1501,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBinaryStream(int, java.io.InputStream, * long) */ @@ -1514,7 +1514,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBlob(int, java.sql.Blob) */ @@ -1525,7 +1525,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBlob(int, java.io.InputStream) */ @@ -1537,7 +1537,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBlob(int, java.io.InputStream, long) */ @@ -1549,7 +1549,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBoolean(int, boolean) */ @@ -1560,7 +1560,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setByte(int, byte) */ @@ -1571,7 +1571,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setBytes(int, byte[]) */ @@ -1582,7 +1582,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setCharacterStream(int, java.io.Reader) */ @@ -1594,7 +1594,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setCharacterStream(int, java.io.Reader, * int) */ @@ -1607,7 +1607,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setCharacterStream(int, java.io.Reader, * long) */ @@ -1620,7 +1620,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setClob(int, java.sql.Clob) */ @@ -1631,7 +1631,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setClob(int, java.io.Reader) */ @@ -1642,7 +1642,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setClob(int, java.io.Reader, long) */ @@ -1654,7 +1654,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setDate(int, java.sql.Date) */ @@ -1665,7 +1665,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setDate(int, java.sql.Date, * java.util.Calendar) */ @@ -1678,7 +1678,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setDouble(int, double) */ @@ -1689,7 +1689,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setFloat(int, float) */ @@ -1700,7 +1700,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setInt(int, int) */ @@ -1711,7 +1711,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setLong(int, long) */ @@ -1722,7 +1722,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNCharacterStream(int, java.io.Reader) */ @@ -1734,7 +1734,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNCharacterStream(int, java.io.Reader, * long) */ @@ -1747,7 +1747,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNClob(int, java.sql.NClob) */ @@ -1758,7 +1758,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNClob(int, java.io.Reader) */ @@ -1769,7 +1769,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNClob(int, java.io.Reader, long) */ @@ -1781,7 +1781,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNString(int, java.lang.String) */ @@ -1792,7 +1792,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNull(int, int) */ @@ -1803,7 +1803,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setNull(int, int, java.lang.String) */ @@ -1815,7 +1815,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setObject(int, java.lang.Object) */ @@ -1826,7 +1826,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setObject(int, java.lang.Object, int) */ @@ -1838,7 +1838,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setObject(int, java.lang.Object, int, int) */ @@ -1850,7 +1850,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setRef(int, java.sql.Ref) */ @@ -1861,7 +1861,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setRowId(int, java.sql.RowId) */ @@ -1872,7 +1872,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setSQLXML(int, java.sql.SQLXML) */ @@ -1884,7 +1884,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setShort(int, short) */ @@ -1895,7 +1895,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setString(int, java.lang.String) */ @@ -1906,7 +1906,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setTime(int, java.sql.Time) */ @@ -1917,7 +1917,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setTime(int, java.sql.Time, * java.util.Calendar) */ @@ -1930,7 +1930,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setTimestamp(int, java.sql.Timestamp) */ @@ -1941,7 +1941,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setTimestamp(int, java.sql.Timestamp, * java.util.Calendar) */ @@ -1954,7 +1954,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setURL(int, java.net.URL) */ @@ -1965,7 +1965,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.PreparedStatement#setUnicodeStream(int, java.io.InputStream, * int) */ @@ -1978,7 +1978,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#addBatch(java.lang.String) */ @@ -1989,7 +1989,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#cancel() */ @@ -2000,7 +2000,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#clearBatch() */ @@ -2011,7 +2011,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#clearWarnings() */ @@ -2022,7 +2022,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#close() */ @@ -2033,7 +2033,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String) */ @@ -2044,7 +2044,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String, int) */ @@ -2055,7 +2055,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String, int[]) */ @@ -2066,7 +2066,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String, java.lang.String[]) */ @@ -2077,7 +2077,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeBatch() */ @@ -2088,7 +2088,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeQuery(java.lang.String) */ @@ -2099,7 +2099,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String) */ @@ -2110,7 +2110,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String, int) */ @@ -2122,7 +2122,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String, int[]) */ @@ -2133,7 +2133,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String, java.lang.String[]) */ @@ -2145,7 +2145,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getConnection() */ @@ -2156,7 +2156,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getFetchDirection() */ @@ -2167,7 +2167,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getFetchSize() */ @@ -2178,7 +2178,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getGeneratedKeys() */ @@ -2189,7 +2189,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMaxFieldSize() */ @@ -2200,7 +2200,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMaxRows() */ @@ -2211,7 +2211,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMoreResults() */ @@ -2222,7 +2222,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMoreResults(int) */ @@ -2233,7 +2233,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getQueryTimeout() */ @@ -2244,7 +2244,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSet() */ @@ -2255,7 +2255,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSetConcurrency() */ @@ -2266,7 +2266,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSetHoldability() */ @@ -2277,7 +2277,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSetType() */ @@ -2288,7 +2288,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getUpdateCount() */ @@ -2299,7 +2299,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getWarnings() */ @@ -2310,7 +2310,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#isClosed() */ @@ -2321,7 +2321,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#isPoolable() */ @@ -2332,7 +2332,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setCursorName(java.lang.String) */ @@ -2343,7 +2343,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setEscapeProcessing(boolean) */ @@ -2354,7 +2354,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setFetchDirection(int) */ @@ -2365,7 +2365,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setFetchSize(int) */ @@ -2376,7 +2376,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setMaxFieldSize(int) */ @@ -2387,7 +2387,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setMaxRows(int) */ @@ -2398,7 +2398,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setPoolable(boolean) */ @@ -2409,7 +2409,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setQueryTimeout(int) */ @@ -2420,7 +2420,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#isWrapperFor(java.lang.Class) */ @@ -2431,7 +2431,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#unwrap(java.lang.Class) */ @@ -2440,4 +2440,24 @@ throw new SQLException("Method not supported"); } + public void closeOnCompletion() throws SQLException { + // TODO Auto-generated method stub + + } + + public boolean isCloseOnCompletion() throws SQLException { + // TODO Auto-generated method stub + return false; + } + + public T getObject(int parameterIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String parameterName, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + } Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveStatement.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveStatement.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveStatement.java (working copy) @@ -67,7 +67,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#addBatch(java.lang.String) */ @@ -77,7 +77,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#cancel() */ @@ -87,7 +87,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#clearBatch() */ @@ -97,7 +97,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#clearWarnings() */ @@ -107,7 +107,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#close() */ @@ -119,7 +119,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String) */ @@ -133,7 +133,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String, int) */ @@ -143,7 +143,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String, int[]) */ @@ -153,7 +153,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#execute(java.lang.String, java.lang.String[]) */ @@ -163,7 +163,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeBatch() */ @@ -173,7 +173,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeQuery(java.lang.String) */ @@ -197,7 +197,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String) */ @@ -212,7 +212,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String, int) */ @@ -222,7 +222,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String, int[]) */ @@ -232,7 +232,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#executeUpdate(java.lang.String, java.lang.String[]) */ @@ -242,7 +242,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getConnection() */ @@ -252,7 +252,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getFetchDirection() */ @@ -262,7 +262,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getFetchSize() */ @@ -272,7 +272,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getGeneratedKeys() */ @@ -282,7 +282,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMaxFieldSize() */ @@ -292,7 +292,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMaxRows() */ @@ -302,7 +302,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMoreResults() */ @@ -312,7 +312,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getMoreResults(int) */ @@ -322,7 +322,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getQueryTimeout() */ @@ -332,7 +332,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSet() */ @@ -342,7 +342,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSetConcurrency() */ @@ -352,7 +352,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSetHoldability() */ @@ -362,7 +362,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getResultSetType() */ @@ -372,7 +372,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getUpdateCount() */ @@ -382,7 +382,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#getWarnings() */ @@ -392,7 +392,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#isClosed() */ @@ -402,7 +402,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#isPoolable() */ @@ -412,7 +412,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setCursorName(java.lang.String) */ @@ -422,7 +422,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setEscapeProcessing(boolean) */ @@ -432,7 +432,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setFetchDirection(int) */ @@ -442,7 +442,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setFetchSize(int) */ @@ -452,7 +452,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setMaxFieldSize(int) */ @@ -462,7 +462,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setMaxRows(int) */ @@ -475,7 +475,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setPoolable(boolean) */ @@ -485,7 +485,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Statement#setQueryTimeout(int) */ @@ -495,7 +495,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#isWrapperFor(java.lang.Class) */ @@ -505,7 +505,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#unwrap(java.lang.Class) */ @@ -513,4 +513,14 @@ throw new SQLException("Method not supported"); } + public void closeOnCompletion() throws SQLException { + // TODO Auto-generated method stub + + } + + public boolean isCloseOnCompletion() throws SQLException { + // TODO Auto-generated method stub + return false; + } + } Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDatabaseMetaData.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDatabaseMetaData.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDatabaseMetaData.java (working copy) @@ -124,6 +124,16 @@ return false; } } + + public T getObject(int columnIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String columnLabel, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } }; } catch (Exception e) { throw new SQLException(e); @@ -256,6 +266,16 @@ return false; } } + + public T getObject(int columnIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String columnLabel, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } }; } catch (Exception e) { throw new SQLException(e); @@ -514,6 +534,16 @@ public boolean next() throws SQLException { return false; } + + public T getObject(int columnIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String columnLabel, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } }; } @@ -563,6 +593,16 @@ return false; } } + + public T getObject(int columnIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String columnLabel, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } }; return result; } @@ -630,6 +670,16 @@ } } + public T getObject(int columnIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String columnLabel, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + }; return result; } @@ -689,6 +739,16 @@ public boolean next() throws SQLException { return false; } + + public T getObject(int columnIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String columnLabel, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } }; } @@ -1086,4 +1146,17 @@ System.out.println("DriverName: " + meta.getDriverName()); System.out.println("DriverVersion: " + meta.getDriverVersion()); } + + @Override + public boolean generatedKeyAlwaysReturned() throws SQLException { + // TODO Auto-generated method stub + return false; + } + + @Override + public ResultSet getPseudoColumns(String catalog, String schemaPattern, String tableNamePattern, + String columnNamePattern) throws SQLException { + // TODO Auto-generated method stub + return null; + } } Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HivePreparedStatement.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HivePreparedStatement.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HivePreparedStatement.java (working copy) @@ -1,5 +1,4 @@ /** - * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file @@ -1263,4 +1262,14 @@ throw new SQLException("Method not supported"); } + public void closeOnCompletion() throws SQLException { + // TODO Auto-generated method stub + + } + + public boolean isCloseOnCompletion() throws SQLException { + // TODO Auto-generated method stub + return false; + } + } Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDataSource.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDataSource.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDataSource.java (working copy) @@ -21,6 +21,8 @@ import java.io.PrintWriter; import java.sql.Connection; import java.sql.SQLException; +import java.sql.SQLFeatureNotSupportedException; +import java.util.logging.Logger; import javax.sql.DataSource; @@ -39,7 +41,7 @@ /* * (non-Javadoc) - * + * * @see javax.sql.DataSource#getConnection() */ @@ -49,7 +51,7 @@ /* * (non-Javadoc) - * + * * @see javax.sql.DataSource#getConnection(java.lang.String, java.lang.String) */ @@ -64,7 +66,7 @@ /* * (non-Javadoc) - * + * * @see javax.sql.CommonDataSource#getLogWriter() */ @@ -75,7 +77,7 @@ /* * (non-Javadoc) - * + * * @see javax.sql.CommonDataSource#getLoginTimeout() */ @@ -86,7 +88,7 @@ /* * (non-Javadoc) - * + * * @see javax.sql.CommonDataSource#setLogWriter(java.io.PrintWriter) */ @@ -97,7 +99,7 @@ /* * (non-Javadoc) - * + * * @see javax.sql.CommonDataSource#setLoginTimeout(int) */ @@ -108,7 +110,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#isWrapperFor(java.lang.Class) */ @@ -119,7 +121,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#unwrap(java.lang.Class) */ @@ -128,4 +130,9 @@ throw new SQLException("Method not supported"); } + public Logger getParentLogger() throws SQLFeatureNotSupportedException { + // TODO Auto-generated method stub + return null; + } + } Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDriver.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDriver.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveDriver.java (working copy) @@ -24,9 +24,11 @@ import java.sql.Driver; import java.sql.DriverPropertyInfo; import java.sql.SQLException; +import java.sql.SQLFeatureNotSupportedException; import java.util.Properties; import java.util.jar.Attributes; import java.util.jar.Manifest; +import java.util.logging.Logger; import java.util.regex.Pattern; /** @@ -86,13 +88,13 @@ /** * Checks whether a given url is in a valid format. - * + * * The current uri format is: jdbc:hive://[host[:port]] - * + * * jdbc:hive:// - run in embedded mode jdbc:hive://localhost - connect to * localhost default port (10000) jdbc:hive://localhost:5050 - connect to * localhost port 5050 - * + * * TODO: - write a better regex. - decide on uri format */ @@ -105,7 +107,7 @@ } /** - * Package scoped access to the Driver's Major Version + * Package scoped access to the Driver's Major Version * @return The Major version number of the driver. -1 if it cannot be determined from the * manifest.mf file. */ @@ -115,7 +117,7 @@ String fullVersion = HiveDriver.fetchManifestAttribute( Attributes.Name.IMPLEMENTATION_VERSION); String[] tokens = fullVersion.split("\\."); //$NON-NLS-1$ - + if(tokens != null && tokens.length > 0 && tokens[0] != null) { version = Integer.parseInt(tokens[0]); } @@ -127,9 +129,9 @@ } return version; } - + /** - * Package scoped access to the Driver's Minor Version + * Package scoped access to the Driver's Minor Version * @return The Minor version number of the driver. -1 if it cannot be determined from the * manifest.mf file. */ @@ -139,7 +141,7 @@ String fullVersion = HiveDriver.fetchManifestAttribute( Attributes.Name.IMPLEMENTATION_VERSION); String[] tokens = fullVersion.split("\\."); //$NON-NLS-1$ - + if(tokens != null && tokens.length > 1 && tokens[1] != null) { version = Integer.parseInt(tokens[1]); } @@ -151,7 +153,7 @@ } return version; } - + /** * Returns the major version of this driver. */ @@ -210,7 +212,7 @@ /** * Takes a url in the form of jdbc:hive://[hostname]:[port]/[db_name] and * parses it. Everything after jdbc:hive// is optional. - * + * * @param url * @param defaults * @return @@ -252,7 +254,7 @@ return urlProps; } - + /** * Lazy-load manifest attributes as needed. */ @@ -260,7 +262,7 @@ /** * Loads the manifest attributes from the jar. - * + * * @throws java.net.MalformedURLException * @throws IOException */ @@ -280,7 +282,7 @@ /** * Package scoped to allow manifest fetching from other HiveDriver classes * Helper to initialize attributes and return one. - * + * * @param attributeName * @return * @throws SQLException @@ -294,4 +296,9 @@ } return manifestAttributes.getValue(attributeName); } + + public Logger getParentLogger() throws SQLFeatureNotSupportedException { + // TODO Auto-generated method stub + return null; + } } Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveConnection.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveConnection.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveConnection.java (working copy) @@ -18,18 +18,6 @@ package org.apache.hadoop.hive.jdbc; -import org.apache.hadoop.hive.conf.HiveConf; -import org.apache.hadoop.hive.metastore.api.MetaException; -import org.apache.hadoop.hive.service.HiveClient; -import org.apache.hadoop.hive.service.HiveInterface; -import org.apache.hadoop.hive.service.HiveServer; -import org.apache.thrift.TException; -import org.apache.thrift.protocol.TBinaryProtocol; -import org.apache.thrift.protocol.TProtocol; -import org.apache.thrift.transport.TSocket; -import org.apache.thrift.transport.TTransport; -import org.apache.thrift.transport.TTransportException; - import java.sql.Array; import java.sql.Blob; import java.sql.CallableStatement; @@ -47,7 +35,20 @@ import java.sql.Struct; import java.util.Map; import java.util.Properties; +import java.util.concurrent.Executor; +import org.apache.hadoop.hive.conf.HiveConf; +import org.apache.hadoop.hive.metastore.api.MetaException; +import org.apache.hadoop.hive.service.HiveClient; +import org.apache.hadoop.hive.service.HiveInterface; +import org.apache.hadoop.hive.service.HiveServer; +import org.apache.thrift.TException; +import org.apache.thrift.protocol.TBinaryProtocol; +import org.apache.thrift.protocol.TProtocol; +import org.apache.thrift.transport.TSocket; +import org.apache.thrift.transport.TTransport; +import org.apache.thrift.transport.TTransportException; + /** * HiveConnection. * @@ -130,7 +131,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#clearWarnings() */ @@ -140,7 +141,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#close() */ @@ -161,7 +162,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#commit() */ @@ -172,7 +173,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createArrayOf(java.lang.String, * java.lang.Object[]) */ @@ -184,7 +185,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createBlob() */ @@ -195,7 +196,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createClob() */ @@ -206,7 +207,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createNClob() */ @@ -217,7 +218,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createSQLXML() */ @@ -228,7 +229,7 @@ /** * Creates a Statement object for sending SQL statements to the database. - * + * * @throws SQLException * if a database access error occurs. * @see java.sql.Connection#createStatement() @@ -243,7 +244,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createStatement(int, int) */ @@ -255,7 +256,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createStatement(int, int, int) */ @@ -267,7 +268,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#createStruct(java.lang.String, java.lang.Object[]) */ @@ -279,7 +280,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getAutoCommit() */ @@ -289,7 +290,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getCatalog() */ @@ -299,7 +300,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getClientInfo() */ @@ -310,7 +311,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getClientInfo(java.lang.String) */ @@ -321,7 +322,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getHoldability() */ @@ -332,7 +333,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getMetaData() */ @@ -342,7 +343,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getTransactionIsolation() */ @@ -352,7 +353,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getTypeMap() */ @@ -363,7 +364,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#getWarnings() */ @@ -373,7 +374,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#isClosed() */ @@ -383,7 +384,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#isReadOnly() */ @@ -393,7 +394,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#isValid(int) */ @@ -404,7 +405,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#nativeSQL(java.lang.String) */ @@ -415,7 +416,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareCall(java.lang.String) */ @@ -426,7 +427,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareCall(java.lang.String, int, int) */ @@ -438,7 +439,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareCall(java.lang.String, int, int, int) */ @@ -450,7 +451,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareStatement(java.lang.String) */ @@ -460,7 +461,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareStatement(java.lang.String, int) */ @@ -471,7 +472,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareStatement(java.lang.String, int[]) */ @@ -483,7 +484,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareStatement(java.lang.String, * java.lang.String[]) */ @@ -496,7 +497,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareStatement(java.lang.String, int, int) */ @@ -507,7 +508,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#prepareStatement(java.lang.String, int, int, int) */ @@ -519,7 +520,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#releaseSavepoint(java.sql.Savepoint) */ @@ -530,7 +531,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#rollback() */ @@ -541,7 +542,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#rollback(java.sql.Savepoint) */ @@ -552,7 +553,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setAutoCommit(boolean) */ @@ -563,7 +564,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setCatalog(java.lang.String) */ @@ -574,7 +575,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setClientInfo(java.util.Properties) */ @@ -586,7 +587,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setClientInfo(java.lang.String, java.lang.String) */ @@ -598,7 +599,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setHoldability(int) */ @@ -609,7 +610,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setReadOnly(boolean) */ @@ -620,7 +621,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setSavepoint() */ @@ -631,7 +632,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setSavepoint(java.lang.String) */ @@ -642,7 +643,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setTransactionIsolation(int) */ @@ -653,7 +654,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Connection#setTypeMap(java.util.Map) */ @@ -664,7 +665,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#isWrapperFor(java.lang.Class) */ @@ -675,7 +676,7 @@ /* * (non-Javadoc) - * + * * @see java.sql.Wrapper#unwrap(java.lang.Class) */ @@ -684,4 +685,29 @@ throw new SQLException("Method not supported"); } + public void abort(Executor executor) throws SQLException { + // TODO Auto-generated method stub + + } + + public int getNetworkTimeout() throws SQLException { + // TODO Auto-generated method stub + return 0; + } + + public String getSchema() throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public void setNetworkTimeout(Executor executor, int milliseconds) throws SQLException { + // TODO Auto-generated method stub + + } + + public void setSchema(String schema) throws SQLException { + // TODO Auto-generated method stub + + } + } Index: jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveQueryResultSet.java =================================================================== --- jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveQueryResultSet.java (revision 1366269) +++ jdbc/src/java/org/apache/hadoop/hive/jdbc/HiveQueryResultSet.java (working copy) @@ -207,4 +207,14 @@ return obj; } + + public T getObject(int columnIndex, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } + + public T getObject(String columnLabel, Class type) throws SQLException { + // TODO Auto-generated method stub + return null; + } } Index: metastore/build.xml =================================================================== --- metastore/build.xml (revision 1366269) +++ metastore/build.xml (working copy) @@ -103,7 +103,7 @@ - +