org.javalite.common.Util.closeQuietly()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(9.5k)|赞(0)|评价(0)|浏览(212)

本文整理了Java中org.javalite.common.Util.closeQuietly()方法的一些代码示例，展示了Util.closeQuietly()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Util.closeQuietly()方法的具体详情如下：
包路径：org.javalite.common.Util
类名称：Util
方法名：closeQuietly

Util.closeQuietly介绍

[英]Closes a resource and swallows exception if thrown during a close.
[中]关闭资源，如果在关闭过程中抛出异常，则接受异常。

代码示例

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Quietly closes the <code>java.sql.PreparedStatement</code> used in a batch execution. The advantage over calling
  3.  * <code>java.sql.PreparedStatement.close()</code> directly is not having to explicitly handle a checked exception
  4.  * (<code>java.sql.SQLException</code>).
  5.  * This method should typically be called in a finally block. So as not to displace any exception (e.g. from a failed
  6.  * batch execution) that might already be in flight, this method swallows any exception that might arise from
  7.  * closing the statement. This is generally seen as a worthwhile trade-off, as it much less likely for a close to fail
  8.  * without a prior failure.
  9.  *
  10.  * @param ps <code>java.sql.PreparedStatement</code> with which a batch has been executed. If null, this is a no-op.
  11.  */
  12. public void closePreparedStatement(PreparedStatement ps) {
  13.   closeQuietly(ps);
  14. }

代码示例来源：origin: javalite/activejdbc

  1. void cleanStatementCache(Connection connection) {
  2.     Map<String, PreparedStatement> stmsMap = statementCache.remove(connection);
  3.     if(stmsMap != null) { //Close prepared statements to release cursors on connection pools
  4.       for(PreparedStatement stmt : stmsMap.values()) {
  5.         closeQuietly(stmt);
  6.       }
  7.     }
  8.   }
  9. }

代码示例来源：origin: javalite/activejdbc

  1. public void with(RowListener listener){
  2.   try {
  3.     processRS(listener);
  4.   } catch(SQLException e) {
  5.     throw new DBException(e);
  6.   } finally {
  7.     //TODO: shouldn't these be closed in the same scope they were created?
  8.     closeQuietly(rs);
  9.     closeQuietly(s);
  10.   }
  11. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Converts stack trace to string.
  3.  *
  4.  * @param throwable - throwable to convert.
  5.  * @return message and stack trace converted to string.
  6.  */
  7. public static String getStackTraceString(Throwable throwable) {
  8.   StringWriter sw = null;
  9.   PrintWriter pw = null;
  10.   try {
  11.     sw = new StringWriter();
  12.     pw = new PrintWriter(sw);
  13.     pw.println(throwable.toString());
  14.     throwable.printStackTrace(pw);
  15.     pw.flush();
  16.     return sw.toString();
  17.   } finally {
  18.     closeQuietly(pw);
  19.     closeQuietly(sw);
  20.   }
  21. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Reads contents of resource fully into a byte array.
  3.  *
  4.  * @param resourceName resource name.
  5.  * @return entire contents of resource as byte array.
  6.  */
  7. public static byte[] readResourceBytes(String resourceName) {
  8.   InputStream is = Util.class.getResourceAsStream(resourceName);
  9.   try {
  10.     return bytes(is);
  11.   } catch (IOException e) {
  12.     throw new RuntimeException(e);
  13.   } finally {
  14.     closeQuietly(is);
  15.   }
  16. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Returns lines of text of a resource as list.
  3.  *
  4.  * @param resourceName name of resource
  5.  * @return list of text lines
  6.  * @throws java.io.IOException in case of IO error
  7.  */
  8. public static List<String> getResourceLines(String resourceName) throws IOException {
  9.   InputStreamReader isreader = null;
  10.   BufferedReader reader = null;
  11.   try {
  12.     isreader = new InputStreamReader(Util.class.getResourceAsStream(resourceName));
  13.     reader = new BufferedReader(isreader);
  14.     List<String> lines = new ArrayList<String>();
  15.     String tmp;
  16.     while ((tmp = reader.readLine()) != null) {
  17.       lines.add(tmp);
  18.     }
  19.     return lines;
  20.   } finally {
  21.     closeQuietly(reader);
  22.     closeQuietly(isreader);
  23.   }
  24. }

代码示例来源：origin: javalite/activejdbc

  1. private static String clobToString(Clob clob) {
  2.   Reader r = null;
  3.   StringWriter sw = null;
  4.   try {
  5.     r = clob.getCharacterStream();
  6.     sw = new StringWriter();
  7.     copyStream(r, sw);
  8.     return sw.toString();
  9.   } catch (Exception e) {
  10.     throw new ConversionException(e);
  11.   } finally {
  12.     closeQuietly(sw);
  13.     closeQuietly(r);
  14.   }
  15. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Reads contents of file fully and returns as string.
  3.  *
  4.  * @param fileName file name.
  5.  * @param charset name of supported charset.
  6.  * @return contents of entire file.
  7.  */
  8. public static String readFile(String fileName, String charset) {
  9.   FileInputStream in = null;
  10.   try {
  11.     in = new FileInputStream(fileName);
  12.     return read(in, charset);
  13.   } catch (IOException e) {
  14.     throw new RuntimeException(e);
  15.   } finally {
  16.     closeQuietly(in);
  17.   }
  18. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Reads file into a byte array.
  3.  *
  4.  * @param file file to read.
  5.  * @return content of file.
  6.  * @throws java.io.IOException
  7.  */
  8. public static byte[] read(File file) throws IOException {
  9.   FileInputStream is = new FileInputStream(file);
  10.   try {
  11.     return bytes(is);
  12.   } finally {
  13.     closeQuietly(is);
  14.   }
  15. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Saves content of byte array to file.
  3.  *
  4.  * @param path path to file - can be absolute or relative to current.
  5.  * @param content bytes to save.
  6.  */
  7. public static void saveTo(String path, byte[] content) {
  8.   InputStream is = null;
  9.   try {
  10.     is = new ByteArrayInputStream(content);
  11.     saveTo(path, is);
  12.   } finally {
  13.     closeQuietly(is);
  14.   }
  15. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Reads contents of the input stream fully and returns it as byte array.
  3.  *
  4.  * @param in InputStream to read from.
  5.  * @return contents of the input stream fully as byte array
  6.  * @throws IOException in case of IO error
  7.  */
  8. public static byte[] bytes(InputStream in) throws IOException {
  9.   if (in == null) {
  10.     throw new IllegalArgumentException("input stream cannot be null");
  11.   }
  12.   ByteArrayOutputStream os = null;
  13.   try {
  14.     os = new ByteArrayOutputStream(1024);
  15.     byte[] bytes = new byte[1024];
  16.     int len;
  17.     while ((len = in.read(bytes)) != -1) {
  18.       os.write(bytes, 0, len);
  19.     }
  20.     return os.toByteArray();
  21.   } finally {
  22.     closeQuietly(os);
  23.   }
  24. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Reads contents of resource fully into a string.
  3.  *
  4.  * @param resourceName resource name.
  5.  * @param charset name of supported charset
  6.  * @return entire contents of resource as string.
  7.  */
  8. public static String readResource(String resourceName, String charset) {
  9.   InputStream is = Util.class.getResourceAsStream(resourceName);
  10.   try {
  11.     return read(is, charset);
  12.   } catch (IOException e) {
  13.     throw new RuntimeException(e);
  14.   } finally {
  15.     closeQuietly(is);
  16.   }
  17. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Reads contents of the input stream fully and returns it as String.
  3.  *
  4.  * @param in InputStream to read from.
  5.  * @param charset name of supported charset to use
  6.  * @return contents of the input stream fully as String.
  7.  * @throws IOException in case of IO error
  8.  */
  9. public static String read(InputStream in, String charset) throws IOException {
  10.   if (in == null) {
  11.     throw new IllegalArgumentException("input stream cannot be null");
  12.   }
  13.   InputStreamReader reader = null;
  14.   try {
  15.     reader = new InputStreamReader(in, charset);
  16.     char[] buffer = new char[1024];
  17.     StringBuilder sb = new StringBuilder();
  18.     int len;
  19.     while ((len = reader.read(buffer)) != -1) {
  20.       sb.append(buffer, 0, len);
  21.     }
  22.     return sb.toString();
  23.   } finally {
  24.     closeQuietly(reader);
  25.   }
  26. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Saves content read from input stream into a file.
  3.  *
  4.  * @param path path to file.
  5.  * @param in  input stream to read content from.
  6.  */
  7. public static void saveTo(String path, InputStream in) {
  8.   if (in == null) {
  9.     throw new IllegalArgumentException("input stream cannot be null");
  10.   }
  11.   if (path == null) {
  12.     throw new IllegalArgumentException("path cannot be null");
  13.   }
  14.   FileOutputStream out = null;
  15.   try {
  16.     out = new FileOutputStream(path);
  17.     byte[] bytes = new byte[1024];
  18.     int len;
  19.     while ((len = in.read(bytes)) != -1) {
  20.       out.write(bytes, 0, len);
  21.     }
  22.     out.flush();
  23.   } catch (IOException e) {
  24.     throw new RuntimeException(e);
  25.   } finally {
  26.     closeQuietly(out);
  27.   }
  28. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Converts <code>java.sql.Blob</code> to bytes array.
  3.  *
  4.  * @param blob Blob to be converted
  5.  * @return blob converted to byte array
  6.  */
  7. public static byte[] toBytes(Blob blob) {
  8.   InputStream is = null;
  9.   try {
  10.     is = blob.getBinaryStream();
  11.     return bytes(is);
  12.   } catch (Exception e) {
  13.     throw new ConversionException(e);
  14.   } finally {
  15.     closeQuietly(is);
  16.   }
  17. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * This method returns the value of the first column of the first row.
  3.  * If query results have more than one column or more than one row, they will be ignored.
  4.  *
  5.  * @param query query
  6.  * @param params parameters
  7.  * @return fetched value, or null if query did not fetch anything.
  8.  */
  9. public Object firstCell(final String query, Object... params) {
  10.   PreparedStatement ps = null;
  11.   ResultSet rs = null;
  12.   try {
  13.     Object result = null;
  14.     long start = System.currentTimeMillis();
  15.     ps = connection().prepareStatement(query);
  16.     setParameters(ps, params);
  17.     rs = ps.executeQuery();
  18.     if (rs.next()) {
  19.       result = rs.getObject(1);
  20.     }
  21.     LogFilter.logQuery(LOGGER, query, params, start);
  22.     return result;
  23.   } catch (SQLException e) {
  24.     throw new DBException(query, params, e);
  25.   } finally {
  26.     closeQuietly(rs);
  27.     closeQuietly(ps);
  28.   }
  29. }

代码示例来源：origin: javalite/activejdbc

  1. throw new DBException(query, params, e);
  2. } finally {
  3.   closeQuietly(rs);
  4.   closeQuietly(ps);

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Executes a raw query and calls instance of <code>RowListener</code> with every row found.
  3.  * Use this method for very large result sets.
  4.  *
  5.  * @param sql raw SQL query.
  6.  * @param listener client listener implementation for processing individual rows.
  7.  */
  8. public void find(String sql, RowListener listener) {
  9.   Statement s = null;
  10.   ResultSet rs = null;
  11.   try {
  12.     s = createStreamingStatement();
  13.     rs = s.executeQuery(sql);
  14.     RowProcessor p = new RowProcessor(rs, s);
  15.     p.with(listener);
  16.   } catch (SQLException e) {
  17.     throw new DBException(sql, null, e);
  18.   } finally {
  19.     closeQuietly(rs);
  20.     closeQuietly(s);
  21.   }
  22. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Executes DML. Use it for inserts and updates.
  3.  *
  4.  * @param query raw DML.
  5.  * @return number of rows afected by query.
  6.  */
  7. public int exec(String query){
  8.   long start = System.currentTimeMillis();
  9.   Statement s = null;
  10.   try {
  11.     s = connection().createStatement();
  12.     int count = s.executeUpdate(query);
  13.     LogFilter.logQuery(LOGGER, query, null, start);
  14.     return count;
  15.   } catch (SQLException e) {
  16.     logException("Query failed: " + query, e);
  17.     throw new DBException(query, null, e);
  18.   } finally {
  19.     closeQuietly(s);
  20.   }
  21. }

代码示例来源：origin: javalite/activejdbc

  1. /**
  2.  * Executes parametrized DML - will contain question marks as placeholders.
  3.  *
  4.  * @param query query to execute - will contain question marks as placeholders.
  5.  * @param params  query parameters.
  6.  * @return number of records affected.
  7.  */
  8. public int exec(String query, Object... params){
  9.   if(query.indexOf('?') == -1) throw new IllegalArgumentException("query must be parametrized");
  10.   long start = System.currentTimeMillis();
  11.   PreparedStatement ps = null;
  12.   try {
  13.     ps = connection().prepareStatement(query);
  14.     setParameters(ps, params);
  15.     int count = ps.executeUpdate();
  16.     LogFilter.logQuery(LOGGER, query, params, start);
  17.     return count;
  18.   } catch (SQLException e) {
  19.     logException("Failed query: " + query, e);
  20.     throw new DBException(query, params, e);
  21.   } finally {
  22.     closeQuietly(ps);
  23.   }
  24. }

内容来源于网络，如有侵权，请联系作者删除！

Util

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com