phoenix5-flume/src/it/java/org/apache/phoenix/flume/JsonEventSerializerIT.java [534:558]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private int countRows(final String fullTableName) throws SQLException {
		if (fullTableName == null){
			throw new NullPointerException();
		}
		Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
		final Connection conn = DriverManager.getConnection(getUrl(), props);
		ResultSet rs = null;
		try {
			rs = conn.createStatement().executeQuery("select count(*) from " + fullTableName);
			int rowsCount = 0;
			while (rs.next()) {
				rowsCount = rs.getInt(1);
			}
			return rowsCount;

		} finally {
			if (rs != null) {
				rs.close();
			}
			if (conn != null) {
				conn.close();
			}
		}

	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



phoenix5-flume/src/it/java/org/apache/phoenix/flume/CsvEventSerializerIT.java [409:433]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	private int countRows(final String fullTableName) throws SQLException {
		if (fullTableName == null){
			throw new NullPointerException();
		}
		Properties props = PropertiesUtil.deepCopy(TEST_PROPERTIES);
		final Connection conn = DriverManager.getConnection(getUrl(), props);
		ResultSet rs = null;
		try {
			rs = conn.createStatement().executeQuery("select count(*) from " + fullTableName);
			int rowsCount = 0;
			while (rs.next()) {
				rowsCount = rs.getInt(1);
			}
			return rowsCount;

		} finally {
			if (rs != null) {
				rs.close();
			}
			if (conn != null) {
				conn.close();
			}
		}

	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -