SleuthkitCase.java

Go to the documentation of this file.

/*
 * Sleuth Kit Data Model
 *
 * Copyright 2011-2017 Basis Technology Corp.
 * Contact: carrier <at> sleuthkit <dot> org
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *       http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.sleuthkit.datamodel;

import com.mchange.v2.c3p0.ComboPooledDataSource;
import com.mchange.v2.c3p0.DataSources;
import com.mchange.v2.c3p0.PooledDataSource;
import java.beans.PropertyVetoException;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.InetAddress;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.nio.file.Paths;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.Date;
import java.util.EnumMap;
import java.util.HashMap;
import java.util.HashSet;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.MissingResourceException;
import java.util.ResourceBundle;
import java.util.Set;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.postgresql.util.PSQLException;
import org.postgresql.util.PSQLState;
import org.sleuthkit.datamodel.BlackboardArtifact.ARTIFACT_TYPE;
import org.sleuthkit.datamodel.BlackboardAttribute.ATTRIBUTE_TYPE;
import org.sleuthkit.datamodel.BlackboardAttribute.TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE;
import org.sleuthkit.datamodel.IngestJobInfo.IngestJobStatusType;
import org.sleuthkit.datamodel.IngestModuleInfo.IngestModuleType;
import org.sleuthkit.datamodel.SleuthkitJNI.CaseDbHandle.AddImageProcess;
import org.sleuthkit.datamodel.TskData.DbType;
import org.sleuthkit.datamodel.TskData.FileKnown;
import org.sleuthkit.datamodel.TskData.ObjectType;
import org.sleuthkit.datamodel.TskData.TSK_DB_FILES_TYPE_ENUM;
import org.sleuthkit.datamodel.TskData.TSK_FS_META_FLAG_ENUM;
import org.sleuthkit.datamodel.TskData.TSK_FS_META_TYPE_ENUM;
import org.sleuthkit.datamodel.TskData.TSK_FS_NAME_FLAG_ENUM;
import org.sleuthkit.datamodel.TskData.TSK_FS_NAME_TYPE_ENUM;
import org.sqlite.SQLiteConfig;
import org.sqlite.SQLiteDataSource;
import org.sqlite.SQLiteJDBCLoader;

public class SleuthkitCase {

        private static final int MAX_DB_NAME_LEN_BEFORE_TIMESTAMP = 47;
        private static final int SCHEMA_VERSION_NUMBER = 6; // This must be the same as TSK_SCHEMA_VER in tsk/auto/tsk_db.h.
        private static final long BASE_ARTIFACT_ID = Long.MIN_VALUE; // Artifact ids will start at the lowest negative value
        private static final Logger logger = Logger.getLogger(SleuthkitCase.class.getName());
        private static final ResourceBundle bundle = ResourceBundle.getBundle("org.sleuthkit.datamodel.Bundle");
        private static final int IS_REACHABLE_TIMEOUT_MS = 1000;
        private static final String SQL_ERROR_CONNECTION_GROUP = "08";
        private static final String SQL_ERROR_AUTHENTICATION_GROUP = "28";
        private static final String SQL_ERROR_PRIVILEGE_GROUP = "42";
        private static final String SQL_ERROR_RESOURCE_GROUP = "53";
        private static final String SQL_ERROR_LIMIT_GROUP = "54";
        private static final String SQL_ERROR_INTERNAL_GROUP = "xx";
        private static final int MIN_USER_DEFINED_TYPE_ID = 10000;
        private final ConnectionPool connections;
        private final Map<Long, VirtualDirectory> rootIdsToCarvedFileDirs = new HashMap<Long, VirtualDirectory>();
        private final Map<Long, FileSystem> fileSystemIdMap = new HashMap<Long, FileSystem>(); // Cache for file system files.
        private final ArrayList<ErrorObserver> sleuthkitCaseErrorObservers = new ArrayList<ErrorObserver>();
        private final String databaseName;
        private final String dbPath;
        private final DbType dbType;
        private final String caseDirPath;
        private SleuthkitJNI.CaseDbHandle caseHandle;
        private int versionNumber;
        private String dbBackupPath;
        private Map<Integer, BlackboardArtifact.Type> typeIdToArtifactTypeMap;
        private Map<Integer, BlackboardAttribute.Type> typeIdToAttributeTypeMap;
        private Map<String, BlackboardArtifact.Type> typeNameToArtifactTypeMap;
        private Map<String, BlackboardAttribute.Type> typeNameToAttributeTypeMap;
        private long nextArtifactId; // Used to ensure artifact ids come from the desired range.
        // This read/write lock is used to implement a layer of locking on top of
        // the locking protocol provided by the underlying SQLite database. The Java
        // locking protocol improves performance for reasons that are not currently
        // understood. Note that the lock is contructed to use a fairness policy.
        private final ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock(true);

        public static void tryConnect(CaseDbConnectionInfo info) throws TskCoreException {
                // Check if we can talk to the database.
                if (info.getHost() == null || info.getHost().isEmpty()) {
                        throw new TskCoreException(bundle.getString("DatabaseConnectionCheck.MissingHostname")); //NON-NLS
                } else if (info.getPort() == null || info.getPort().isEmpty()) {
                        throw new TskCoreException(bundle.getString("DatabaseConnectionCheck.MissingPort")); //NON-NLS
                } else if (info.getUserName() == null || info.getUserName().isEmpty()) {
                        throw new TskCoreException(bundle.getString("DatabaseConnectionCheck.MissingUsername")); //NON-NLS
                } else if (info.getPassword() == null || info.getPassword().isEmpty()) {
                        throw new TskCoreException(bundle.getString("DatabaseConnectionCheck.MissingPassword")); //NON-NLS
                }

                try {
                        Class.forName("org.postgresql.Driver"); //NON-NLS
                        Connection conn = DriverManager.getConnection("jdbc:postgresql://" + info.getHost() + ":" + info.getPort() + "/postgres", info.getUserName(), info.getPassword()); //NON-NLS
                        if (conn != null) {
                                conn.close();
                        }
                } catch (SQLException ex) {
                        String result;
                        String sqlState = ex.getSQLState().toLowerCase();
                        if (sqlState.startsWith(SQL_ERROR_CONNECTION_GROUP)) {
                                try {
                                        if (InetAddress.getByName(info.getHost()).isReachable(IS_REACHABLE_TIMEOUT_MS)) {
                                                // if we can reach the host, then it's probably port problem
                                                result = bundle.getString("DatabaseConnectionCheck.Port"); //NON-NLS
                                        } else {
                                                result = bundle.getString("DatabaseConnectionCheck.HostnameOrPort"); //NON-NLS
                                        }
                                } catch (IOException any) {
                                        // it may be anything
                                        result = bundle.getString("DatabaseConnectionCheck.Everything"); //NON-NLS
                                } catch (MissingResourceException any) {
                                        // it may be anything
                                        result = bundle.getString("DatabaseConnectionCheck.Everything"); //NON-NLS
                                }
                        } else if (sqlState.startsWith(SQL_ERROR_AUTHENTICATION_GROUP)) {
                                result = bundle.getString("DatabaseConnectionCheck.Authentication"); //NON-NLS
                        } else if (sqlState.startsWith(SQL_ERROR_PRIVILEGE_GROUP)) {
                                result = bundle.getString("DatabaseConnectionCheck.Access"); //NON-NLS
                        } else if (sqlState.startsWith(SQL_ERROR_RESOURCE_GROUP)) {
                                result = bundle.getString("DatabaseConnectionCheck.ServerDiskSpace"); //NON-NLS
                        } else if (sqlState.startsWith(SQL_ERROR_LIMIT_GROUP)) {
                                result = bundle.getString("DatabaseConnectionCheck.ServerRestart"); //NON-NLS
                        } else if (sqlState.startsWith(SQL_ERROR_INTERNAL_GROUP)) {
                                result = bundle.getString("DatabaseConnectionCheck.InternalServerIssue"); //NON-NLS
                        } else {
                                result = bundle.getString("DatabaseConnectionCheck.Connection"); //NON-NLS
                        }
                        throw new TskCoreException(result);
                } catch (ClassNotFoundException ex) {
                        throw new TskCoreException(bundle.getString("DatabaseConnectionCheck.Installation")); //NON-NLS
                }
        }

        private SleuthkitCase(String dbPath, SleuthkitJNI.CaseDbHandle caseHandle, DbType dbType) throws Exception {
                Class.forName("org.sqlite.JDBC");
                this.dbPath = dbPath;
                this.dbType = dbType;
                File dbFile = new File(dbPath);
                this.caseDirPath = dbFile.getParentFile().getAbsolutePath();
                this.databaseName = dbFile.getName();
                this.connections = new SQLiteConnections(dbPath);
                this.caseHandle = caseHandle;
                init();
                logSQLiteJDBCDriverInfo();
        }

        private SleuthkitCase(String host, int port, String dbName, String userName, String password, SleuthkitJNI.CaseDbHandle caseHandle, String caseDirPath, DbType dbType) throws Exception {
                this.dbPath = "";
                this.databaseName = dbName;
                this.dbType = dbType;
                this.caseDirPath = caseDirPath;
                this.connections = new PostgreSQLConnections(host, port, dbName, userName, password);
                this.caseHandle = caseHandle;
                init();
        }

        private void init() throws Exception {
                typeIdToArtifactTypeMap = new ConcurrentHashMap<Integer, BlackboardArtifact.Type>();
                typeIdToAttributeTypeMap = new ConcurrentHashMap<Integer, BlackboardAttribute.Type>();
                typeNameToArtifactTypeMap = new ConcurrentHashMap<String, BlackboardArtifact.Type>();
                typeNameToAttributeTypeMap = new ConcurrentHashMap<String, BlackboardAttribute.Type>();

                /*
                 * The following methods need to be called before updateDatabaseSchema
                 * due to the way that updateFromSchema2toSchema3 was implemented.
                 */
                initBlackboardArtifactTypes();
                initBlackboardAttributeTypes();
                initNextArtifactId();

                updateDatabaseSchema(null);

                initStandardTagNames();

                CaseDbConnection connection = connections.getConnection();
                initIngestModuleTypes(connection);
                initIngestStatusTypes(connection);
                initReviewStatuses(connection);
                initEncodingTypes(connection);
                connection.close();
        }

        private void initBlackboardArtifactTypes() throws SQLException, TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        for (ARTIFACT_TYPE type : ARTIFACT_TYPE.values()) {
                                try {
                                        statement.execute("INSERT INTO blackboard_artifact_types (artifact_type_id, type_name, display_name) VALUES (" + type.getTypeID() + " , '" + type.getLabel() + "', '" + type.getDisplayName() + "')"); //NON-NLS
                                } catch (SQLException ex) {
                                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) AS count FROM blackboard_artifact_types WHERE artifact_type_id = '" + type.getTypeID() + "'"); //NON-NLS
                                        resultSet.next();
                                        if (resultSet.getLong("count") == 0) {
                                                throw ex;
                                        }
                                        resultSet.close();
                                        resultSet = null;
                                }
                                this.typeIdToArtifactTypeMap.put(type.getTypeID(), new BlackboardArtifact.Type(type));
                                this.typeNameToArtifactTypeMap.put(type.getLabel(), new BlackboardArtifact.Type(type));
                        }
                        if (dbType == DbType.POSTGRESQL) {
                                int newPrimaryKeyIndex = Collections.max(Arrays.asList(ARTIFACT_TYPE.values())).getTypeID() + 1;
                                statement.execute("ALTER SEQUENCE blackboard_artifact_types_artifact_type_id_seq RESTART WITH " + newPrimaryKeyIndex); //NON-NLS
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        private void initBlackboardAttributeTypes() throws SQLException, TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        for (ATTRIBUTE_TYPE type : ATTRIBUTE_TYPE.values()) {
                                try {
                                        statement.execute("INSERT INTO blackboard_attribute_types (attribute_type_id, type_name, display_name, value_type) VALUES (" + type.getTypeID() + ", '" + type.getLabel() + "', '" + type.getDisplayName() + "', '" + type.getValueType().getType() + "')"); //NON-NLS
                                } catch (SQLException ex) {
                                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) AS count FROM blackboard_attribute_types WHERE attribute_type_id = '" + type.getTypeID() + "'"); //NON-NLS
                                        resultSet.next();
                                        if (resultSet.getLong("count") == 0) {
                                                throw ex;
                                        }
                                        resultSet.close();
                                        resultSet = null;
                                }
                                this.typeIdToAttributeTypeMap.put(type.getTypeID(), new BlackboardAttribute.Type(type));
                                this.typeNameToAttributeTypeMap.put(type.getLabel(), new BlackboardAttribute.Type(type));
                        }
                        if (this.dbType == DbType.POSTGRESQL) {
                                int newPrimaryKeyIndex = Collections.max(Arrays.asList(ATTRIBUTE_TYPE.values())).getTypeID() + 1;
                                statement.execute("ALTER SEQUENCE blackboard_attribute_types_attribute_type_id_seq RESTART WITH " + newPrimaryKeyIndex); //NON-NLS
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        private void initNextArtifactId() throws SQLException, TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        resultSet = connection.executeQuery(statement, "SELECT MAX(artifact_id) AS max_artifact_id FROM blackboard_artifacts"); //NON-NLS
                        resultSet.next();
                        this.nextArtifactId = resultSet.getLong("max_artifact_id") + 1;
                        if (this.nextArtifactId == 1) {
                                this.nextArtifactId = BASE_ARTIFACT_ID;
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        private void initStandardTagNames() throws SQLException, TskCoreException {
                String bookmarkDisplayName = bundle.getString("SleuthkitCase.initStandardTagNames.bookmark.text");
                CaseDbConnection connection = connections.getConnection();
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        statement.execute("INSERT INTO tag_names (display_name, description, color) VALUES ('" + bookmarkDisplayName + "', '', '" + TagName.HTML_COLOR.NONE.getName() + "');"); //NON-NLS
                } catch (SQLException ex) {
                        /*
                         * If the exception is a violation of the tag names uniqueness
                         * constraint, it can be ignored because another user has added the
                         * tag name. Otherwise, propagate the exception.
                         */
                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) AS count FROM tag_names WHERE display_name = '" + bookmarkDisplayName + "'"); //NON-NLS
                        resultSet.next();
                        if (resultSet.getLong("count") == 0) {
                                throw ex;
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        private void initIngestModuleTypes(CaseDbConnection connection) throws SQLException, TskCoreException {
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        for (IngestModuleType type : IngestModuleType.values()) {
                                try {
                                        statement.execute("INSERT INTO ingest_module_types (type_id, type_name) VALUES (" + type.ordinal() + ", '" + type.toString() + "');"); //NON-NLS
                                } catch (SQLException ex) {
                                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) as count FROM ingest_module_types WHERE type_id = " + type.ordinal() + ";"); //NON-NLS
                                        resultSet.next();
                                        if (resultSet.getLong("count") == 0) {
                                                throw ex;
                                        }
                                        resultSet.close();
                                        resultSet = null;
                                }
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                }
        }

        private void initIngestStatusTypes(CaseDbConnection connection) throws SQLException, TskCoreException {
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        for (IngestJobStatusType type : IngestJobStatusType.values()) {
                                try {
                                        statement.execute("INSERT INTO ingest_job_status_types (type_id, type_name) VALUES (" + type.ordinal() + ", '" + type.toString() + "');"); //NON-NLS
                                } catch (SQLException ex) {
                                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) as count FROM ingest_job_status_types WHERE type_id = " + type.ordinal() + ";"); //NON-NLS
                                        resultSet.next();
                                        if (resultSet.getLong("count") == 0) {
                                                throw ex;
                                        }
                                        resultSet.close();
                                        resultSet = null;
                                }
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                }
        }

        private void initReviewStatuses(CaseDbConnection connection) throws SQLException, TskCoreException {
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        for (BlackboardArtifact.ReviewStatus status : BlackboardArtifact.ReviewStatus.values()) {
                                try {
                                        statement.execute("INSERT INTO review_statuses (review_status_id, review_status_name, display_name) " //NON-NLS
                                                        + "VALUES (" + status.getID() + ",'" + status.getName() + "','" + status.getDisplayName() + "')"); //NON-NLS
                                } catch (SQLException ex) {
                                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) as count FROM review_statuses WHERE review_status_id = " + status.getID()); //NON-NLS
                                        resultSet.next();
                                        if (resultSet.getLong("count") == 0) {
                                                throw ex;
                                        }
                                        resultSet.close();
                                        resultSet = null;
                                }
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                }
        }

        private void initEncodingTypes(CaseDbConnection connection) throws SQLException, TskCoreException {
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        for (TskData.EncodingType type : TskData.EncodingType.values()) {
                                try {
                                        statement.execute("INSERT INTO file_encoding_types (encoding_type, name) VALUES (" + type.getType() + " , '" + type.name() + "')"); //NON-NLS
                                } catch (SQLException ex) {
                                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) as count FROM file_encoding_types WHERE encoding_type = " + type.getType()); //NON-NLS
                                        resultSet.next();
                                        if (resultSet.getLong("count") == 0) {
                                                throw ex;
                                        }
                                        resultSet.close();
                                        resultSet = null;
                                }
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                }
        }

        private void updateDatabaseSchema(String dbPath) throws Exception {
                CaseDbConnection connection = connections.getConnection();
                ResultSet resultSet = null;
                Statement statement = null;
                try {
                        connection.beginTransaction();

                        // Get the schema version number of the case database from the tsk_db_info table.
                        int schemaVersionNumber = SCHEMA_VERSION_NUMBER;
                        statement = connection.createStatement();
                        resultSet = connection.executeQuery(statement, "SELECT schema_ver FROM tsk_db_info"); //NON-NLS
                        if (resultSet.next()) {
                                schemaVersionNumber = resultSet.getInt("schema_ver"); //NON-NLS
                        }
                        resultSet.close();
                        resultSet = null;
                        statement.close();
                        statement = null;

                        // Do the schema update(s), if needed.
                        if (SCHEMA_VERSION_NUMBER != schemaVersionNumber) {
                                if (null != dbPath) {
                                        // Make a backup copy of the database. Client code can get the path of the backup
                                        // using the getBackupDatabasePath() method.
                                        String backupFilePath = dbPath + ".schemaVer" + schemaVersionNumber + ".backup"; //NON-NLS
                                        copyCaseDB(backupFilePath);
                                        dbBackupPath = backupFilePath;
                                }

                                // ***CALL SCHEMA UPDATE METHODS HERE***
                                // Each method should examine the schema number passed to it and either:
                                //    a. do nothing and return the schema version number unchanged, or
                                //    b. upgrade the database and then increment and return the schema version number.
                                schemaVersionNumber = updateFromSchema2toSchema3(schemaVersionNumber, connection);
                                schemaVersionNumber = updateFromSchema3toSchema4(schemaVersionNumber, connection);
                                schemaVersionNumber = updateFromSchema4toSchema5(schemaVersionNumber, connection);
                                schemaVersionNumber = updateFromSchema5toSchema6(schemaVersionNumber, connection);

                                // Write the updated schema version number to the the tsk_db_info table.
                                statement = connection.createStatement();
                                connection.executeUpdate(statement, "UPDATE tsk_db_info SET schema_ver = " + schemaVersionNumber); //NON-NLS
                                statement.close();
                                statement = null;
                        }
                        versionNumber = schemaVersionNumber;

                        connection.commitTransaction();
                } catch (Exception ex) { // Cannot do exception multi-catch in Java 6, so use catch-all.
                        connection.rollbackTransaction();
                        throw ex;
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        public void copyCaseDB(String newDBPath) throws IOException {
                if (dbPath.isEmpty()) {
                        throw new IOException("Copying case database files is not supported for this type of case database"); //NON-NLS
                }
                InputStream in = null;
                OutputStream out = null;
                acquireExclusiveLock();
                try {
                        InputStream inFile = new FileInputStream(dbPath);
                        in = new BufferedInputStream(inFile);
                        OutputStream outFile = new FileOutputStream(newDBPath);
                        out = new BufferedOutputStream(outFile);
                        int bytesRead = in.read();
                        while (bytesRead != -1) {
                                out.write(bytesRead);
                                bytesRead = in.read();
                        }
                } finally {
                        try {
                                if (in != null) {
                                        in.close();
                                }
                                if (out != null) {
                                        out.flush();
                                        out.close();
                                }
                        } catch (IOException e) {
                                logger.log(Level.WARNING, "Could not close streams after db copy", e); //NON-NLS
                        }
                        releaseExclusiveLock();
                }
        }

        private void logSQLiteJDBCDriverInfo() {
                try {
                        SleuthkitCase.logger.info(String.format("sqlite-jdbc version %s loaded in %s mode", //NON-NLS
                                        SQLiteJDBCLoader.getVersion(), SQLiteJDBCLoader.isNativeMode()
                                        ? "native" : "pure-java")); //NON-NLS
                } catch (Exception ex) {
                        SleuthkitCase.logger.log(Level.SEVERE, "Error querying case database mode", ex);
                }
        }

        @SuppressWarnings("deprecation")
        private int updateFromSchema2toSchema3(int schemaVersionNumber, CaseDbConnection connection) throws SQLException, TskCoreException {
                if (schemaVersionNumber != 2) {
                        return schemaVersionNumber;
                }
                Statement statement = null;
                Statement updateStatement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();

                        // Add new tables for tags.
                        statement.execute("CREATE TABLE tag_names (tag_name_id INTEGER PRIMARY KEY, display_name TEXT UNIQUE, description TEXT NOT NULL, color TEXT NOT NULL)"); //NON-NLS
                        statement.execute("CREATE TABLE content_tags (tag_id INTEGER PRIMARY KEY, obj_id INTEGER NOT NULL, tag_name_id INTEGER NOT NULL, comment TEXT NOT NULL, begin_byte_offset INTEGER NOT NULL, end_byte_offset INTEGER NOT NULL)"); //NON-NLS
                        statement.execute("CREATE TABLE blackboard_artifact_tags (tag_id INTEGER PRIMARY KEY, artifact_id INTEGER NOT NULL, tag_name_id INTEGER NOT NULL, comment TEXT NOT NULL)"); //NON-NLS

                        // Add a new table for reports.
                        statement.execute("CREATE TABLE reports (report_id INTEGER PRIMARY KEY, path TEXT NOT NULL, crtime INTEGER NOT NULL, src_module_name TEXT NOT NULL, report_name TEXT NOT NULL)"); //NON-NLS

                        // Add new columns to the image info table.
                        statement.execute("ALTER TABLE tsk_image_info ADD COLUMN size INTEGER;"); //NON-NLS
                        statement.execute("ALTER TABLE tsk_image_info ADD COLUMN md5 TEXT;"); //NON-NLS
                        statement.execute("ALTER TABLE tsk_image_info ADD COLUMN display_name TEXT;"); //NON-NLS

                        // Add a new column to the file system info table.
                        statement.execute("ALTER TABLE tsk_fs_info ADD COLUMN display_name TEXT;"); //NON-NLS

                        // Add a new column to the file table.
                        statement.execute("ALTER TABLE tsk_files ADD COLUMN meta_seq INTEGER;"); //NON-NLS

                        // Add new columns and indexes to the attributes table and populate the
                        // new column. Note that addition of the new column is a denormalization
                        // to optimize attribute queries.
                        statement.execute("ALTER TABLE blackboard_attributes ADD COLUMN artifact_type_id INTEGER NULL NOT NULL DEFAULT -1;"); //NON-NLS
                        statement.execute("CREATE INDEX attribute_artifactTypeId ON blackboard_attributes(artifact_type_id);"); //NON-NLS
                        statement.execute("CREATE INDEX attribute_valueText ON blackboard_attributes(value_text);"); //NON-NLS
                        statement.execute("CREATE INDEX attribute_valueInt32 ON blackboard_attributes(value_int32);"); //NON-NLS
                        statement.execute("CREATE INDEX attribute_valueInt64 ON blackboard_attributes(value_int64);"); //NON-NLS
                        statement.execute("CREATE INDEX attribute_valueDouble ON blackboard_attributes(value_double);"); //NON-NLS
                        resultSet = statement.executeQuery("SELECT attrs.artifact_id AS artifact_id, " //NON-NLS
                                        + "arts.artifact_type_id AS artifact_type_id " //NON-NLS
                                        + "FROM blackboard_attributes AS attrs " //NON-NLS
                                        + "INNER JOIN blackboard_artifacts AS arts " //NON-NLS
                                        + "WHERE attrs.artifact_id = arts.artifact_id;"); //NON-NLS
                        updateStatement = connection.createStatement();
                        while (resultSet.next()) {
                                long artifactId = resultSet.getLong("artifact_id");
                                int artifactTypeId = resultSet.getInt("artifact_type_id");
                                updateStatement.executeUpdate(
                                                "UPDATE blackboard_attributes " //NON-NLS
                                                + "SET artifact_type_id = " + artifactTypeId //NON-NLS
                                                + " WHERE blackboard_attributes.artifact_id = " + artifactId + ";"); //NON-NLS
                        }
                        resultSet.close();
                        resultSet = null;

                        // Convert existing tag artifact and attribute rows to rows in the new tags tables.
                        // TODO: This code depends on prepared statements that could evolve with
                        // time, breaking this upgrade. The code that follows should be rewritten
                        // to do everything with SQL specific to case database schema version 2.
                        HashMap<String, TagName> tagNames = new HashMap<String, TagName>();
                        for (BlackboardArtifact artifact : getBlackboardArtifacts(ARTIFACT_TYPE.TSK_TAG_FILE)) {
                                Content content = getContentById(artifact.getObjectID());
                                String name = ""; //NON-NLS
                                String comment = ""; //NON-NLS
                                ArrayList<BlackboardAttribute> attributes = getBlackboardAttributes(artifact);
                                for (BlackboardAttribute attribute : attributes) {
                                        if (attribute.getAttributeTypeID() == ATTRIBUTE_TYPE.TSK_TAG_NAME.getTypeID()) {
                                                name = attribute.getValueString();
                                        } else if (attribute.getAttributeTypeID() == ATTRIBUTE_TYPE.TSK_COMMENT.getTypeID()) {
                                                comment = attribute.getValueString();
                                        }
                                }
                                if (!name.isEmpty()) {
                                        TagName tagName;
                                        if (tagNames.containsKey(name)) {
                                                tagName = tagNames.get(name);
                                        } else {
                                                tagName = addTagName(name, "", TagName.HTML_COLOR.NONE); //NON-NLS
                                                tagNames.put(name, tagName);
                                        }
                                        addContentTag(content, tagName, comment, 0, content.getSize() - 1);
                                }
                        }
                        for (BlackboardArtifact artifact : getBlackboardArtifacts(ARTIFACT_TYPE.TSK_TAG_ARTIFACT)) {
                                long taggedArtifactId = -1;
                                String name = ""; //NON-NLS
                                String comment = ""; //NON-NLS
                                ArrayList<BlackboardAttribute> attributes = getBlackboardAttributes(artifact);
                                for (BlackboardAttribute attribute : attributes) {
                                        if (attribute.getAttributeTypeID() == ATTRIBUTE_TYPE.TSK_TAG_NAME.getTypeID()) {
                                                name = attribute.getValueString();
                                        } else if (attribute.getAttributeTypeID() == ATTRIBUTE_TYPE.TSK_COMMENT.getTypeID()) {
                                                comment = attribute.getValueString();
                                        } else if (attribute.getAttributeTypeID() == ATTRIBUTE_TYPE.TSK_TAGGED_ARTIFACT.getTypeID()) {
                                                taggedArtifactId = attribute.getValueLong();
                                        }
                                }
                                if (taggedArtifactId != -1 && !name.isEmpty()) {
                                        TagName tagName;
                                        if (tagNames.containsKey(name)) {
                                                tagName = tagNames.get(name);
                                        } else {
                                                tagName = addTagName(name, "", TagName.HTML_COLOR.NONE); //NON-NLS
                                                tagNames.put(name, tagName);
                                        }
                                        addBlackboardArtifactTag(getBlackboardArtifact(taggedArtifactId), tagName, comment);
                                }
                        }
                        statement.execute(
                                        "DELETE FROM blackboard_attributes WHERE artifact_id IN " //NON-NLS
                                        + "(SELECT artifact_id FROM blackboard_artifacts WHERE artifact_type_id = " //NON-NLS
                                        + ARTIFACT_TYPE.TSK_TAG_FILE.getTypeID()
                                        + " OR artifact_type_id = " + ARTIFACT_TYPE.TSK_TAG_ARTIFACT.getTypeID() + ");"); //NON-NLS
                        statement.execute(
                                        "DELETE FROM blackboard_artifacts WHERE artifact_type_id = " //NON-NLS
                                        + ARTIFACT_TYPE.TSK_TAG_FILE.getTypeID()
                                        + " OR artifact_type_id = " + ARTIFACT_TYPE.TSK_TAG_ARTIFACT.getTypeID() + ";"); //NON-NLS

                        return 3;
                } finally {
                        closeStatement(updateStatement);
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        private int updateFromSchema3toSchema4(int schemaVersionNumber, CaseDbConnection connection) throws SQLException, TskCoreException {
                if (schemaVersionNumber != 3) {
                        return schemaVersionNumber;
                }

                Statement statement = null;
                ResultSet resultSet = null;
                Statement queryStatement = null;
                ResultSet queryResultSet = null;
                Statement updateStatement = null;
                try {
                        // Add mime_type column to tsk_files table. Populate with general
                        // info artifact file signature data.
                        statement = connection.createStatement();
                        updateStatement = connection.createStatement();
                        statement.execute("ALTER TABLE tsk_files ADD COLUMN mime_type TEXT;");
                        resultSet = statement.executeQuery("SELECT files.obj_id AS obj_id, attrs.value_text AS value_text "
                                        + "FROM tsk_files AS files, blackboard_attributes AS attrs, blackboard_artifacts AS arts "
                                        + "WHERE files.obj_id = arts.obj_id AND "
                                        + "arts.artifact_id = attrs.artifact_id AND "
                                        + "arts.artifact_type_id = 1 AND "
                                        + "attrs.attribute_type_id = 62");
                        while (resultSet.next()) {
                                updateStatement.executeUpdate(
                                                "UPDATE tsk_files " //NON-NLS
                                                + "SET mime_type = '" + resultSet.getString("value_text") + "' " //NON-NLS
                                                + "WHERE tsk_files.obj_id = " + resultSet.getInt("obj_id") + ";"); //NON-NLS
                        }
                        resultSet.close();

                        // Add value_type column to blackboard_attribute_types table.
                        statement.execute("ALTER TABLE blackboard_attribute_types ADD COLUMN value_type INTEGER NOT NULL DEFAULT -1;");
                        resultSet = statement.executeQuery("SELECT * FROM blackboard_attribute_types AS types"); //NON-NLS
                        while (resultSet.next()) {
                                int attributeTypeId = resultSet.getInt("attribute_type_id");
                                String attributeLabel = resultSet.getString("type_name");
                                if (attributeTypeId < MIN_USER_DEFINED_TYPE_ID) {
                                        updateStatement.executeUpdate(
                                                        "UPDATE blackboard_attribute_types " //NON-NLS
                                                        + "SET value_type = " + ATTRIBUTE_TYPE.fromLabel(attributeLabel).getValueType().getType() + " " //NON-NLS
                                                        + "WHERE blackboard_attribute_types.attribute_type_id = " + attributeTypeId + ";"); //NON-NLS
                                }
                        }
                        resultSet.close();

                        // Add a data_sources_info table.
                        queryStatement = connection.createStatement();
                        statement.execute("CREATE TABLE data_source_info (obj_id INTEGER PRIMARY KEY, device_id TEXT NOT NULL, time_zone TEXT NOT NULL, FOREIGN KEY(obj_id) REFERENCES tsk_objects(obj_id));");
                        resultSet = statement.executeQuery("SELECT * FROM tsk_objects WHERE par_obj_id IS NULL");
                        while (resultSet.next()) {
                                long objectId = resultSet.getLong("obj_id");
                                String timeZone = "";
                                queryResultSet = queryStatement.executeQuery("SELECT tzone FROM tsk_image_info WHERE obj_id = " + objectId);
                                if (queryResultSet.next()) {
                                        timeZone = queryResultSet.getString("tzone");
                                }
                                queryResultSet.close();
                                updateStatement.executeUpdate("INSERT INTO data_source_info (obj_id, device_id, time_zone) "
                                                + "VALUES(" + objectId + ", '" + UUID.randomUUID().toString() + "' , '" + timeZone + "');");
                        }
                        resultSet.close();

                        // Add data_source_obj_id column to the tsk_files table.
                        //
                        // NOTE: A new case database will have the following FK constraint:
                        //
                        // REFERENCES data_source_info (obj_id)
                        //
                        // The constraint is sacrificed here to avoid having to create and
                        // populate a new tsk_files table.
                        //
                        // TODO: Do this right.
                        statement.execute("ALTER TABLE tsk_files ADD COLUMN data_source_obj_id BIGINT NOT NULL DEFAULT -1;");
                        resultSet = statement.executeQuery("SELECT tsk_files.obj_id AS obj_id, par_obj_id FROM tsk_files, tsk_objects WHERE tsk_files.obj_id = tsk_objects.obj_id");
                        while (resultSet.next()) {
                                long fileId = resultSet.getLong("obj_id");
                                long dataSourceId = getDataSourceObjectId(connection, fileId);
                                updateStatement.executeUpdate("UPDATE tsk_files SET data_source_obj_id = " + dataSourceId + " WHERE obj_id = " + fileId + ";");
                        }
                        resultSet.close();
                        statement.execute("CREATE TABLE ingest_module_types (type_id INTEGER PRIMARY KEY, type_name TEXT NOT NULL)"); //NON-NLS
                        statement.execute("CREATE TABLE ingest_job_status_types (type_id INTEGER PRIMARY KEY, type_name TEXT NOT NULL)"); //NON-NLS
                        if (this.dbType.equals(DbType.SQLITE)) {
                                statement.execute("CREATE TABLE ingest_modules (ingest_module_id INTEGER PRIMARY KEY, display_name TEXT NOT NULL, unique_name TEXT UNIQUE NOT NULL, type_id INTEGER NOT NULL, version TEXT NOT NULL, FOREIGN KEY(type_id) REFERENCES ingest_module_types(type_id));"); //NON-NLS
                                statement.execute("CREATE TABLE ingest_jobs (ingest_job_id INTEGER PRIMARY KEY, obj_id BIGINT NOT NULL, host_name TEXT NOT NULL, start_date_time BIGINT NOT NULL, end_date_time BIGINT NOT NULL, status_id INTEGER NOT NULL, settings_dir TEXT, FOREIGN KEY(obj_id) REFERENCES tsk_objects(obj_id), FOREIGN KEY(status_id) REFERENCES ingest_job_status_types(type_id));"); //NON-NLS
                        } else {
                                statement.execute("CREATE TABLE ingest_modules (ingest_module_id BIGSERIAL PRIMARY KEY, display_name TEXT NOT NULL, unique_name TEXT UNIQUE NOT NULL, type_id INTEGER NOT NULL, version TEXT NOT NULL, FOREIGN KEY(type_id) REFERENCES ingest_module_types(type_id));"); //NON-NLS
                                statement.execute("CREATE TABLE ingest_jobs (ingest_job_id BIGSERIAL PRIMARY KEY, obj_id BIGINT NOT NULL, host_name TEXT NOT NULL, start_date_time BIGINT NOT NULL, end_date_time BIGINT NOT NULL, status_id INTEGER NOT NULL, settings_dir TEXT, FOREIGN KEY(obj_id) REFERENCES tsk_objects(obj_id), FOREIGN KEY(status_id) REFERENCES ingest_job_status_types(type_id));"); //NON-NLS
                        }

                        statement.execute("CREATE TABLE ingest_job_modules (ingest_job_id INTEGER, ingest_module_id INTEGER, pipeline_position INTEGER, PRIMARY KEY(ingest_job_id, ingest_module_id), FOREIGN KEY(ingest_job_id) REFERENCES ingest_jobs(ingest_job_id), FOREIGN KEY(ingest_module_id) REFERENCES ingest_modules(ingest_module_id));"); //NON-NLS
                        initIngestModuleTypes(connection);
                        initIngestStatusTypes(connection);

                        return 4;

                } finally {
                        closeResultSet(queryResultSet);
                        closeStatement(queryStatement);
                        closeStatement(updateStatement);
                        closeResultSet(resultSet);
                        closeStatement(statement);
                }
        }

        private int updateFromSchema4toSchema5(int schemaVersionNumber, CaseDbConnection connection) throws SQLException, TskCoreException {
                if (schemaVersionNumber != 4) {
                        return schemaVersionNumber;
                }

                Statement statement = null;
                try {
                        // Add the review_statuses lookup table.
                        statement = connection.createStatement();
                        statement.execute("CREATE TABLE review_statuses (review_status_id INTEGER PRIMARY KEY, review_status_name TEXT NOT NULL, display_name TEXT NOT NULL)");

                        /*
                         * Add review_status_id column to artifacts table.
                         *
                         * NOTE: For DBs created with schema 5 we define a foreign key
                         * constraint on the review_status_column. We don't bother with this
                         * for DBs updated to schema 5 because of limitations of the SQLite
                         * ALTER TABLE command.
                         */
                        statement.execute("ALTER TABLE blackboard_artifacts ADD COLUMN review_status_id INTEGER NOT NULL DEFAULT " + BlackboardArtifact.ReviewStatus.UNDECIDED.getID());

                        // Add the encoding table
                        statement.execute("CREATE TABLE file_encoding_types (encoding_type INTEGER PRIMARY KEY, name TEXT NOT NULL);");
                        initEncodingTypes(connection);

                        /*
                         * This needs to be done due to a Autopsy/TSK out of synch problem.
                         * Without this, it is possible to upgrade from version 4 to 5 and
                         * then 5 to 6, but not from 4 to 6.
                         */
                        initReviewStatuses(connection);

                        // Add encoding type column to tsk_files_path
                        // This should really have the FOREIGN KEY constraint but there are problems
                        // getting that to work, so we don't add it on this upgrade path.
                        statement.execute("ALTER TABLE tsk_files_path ADD COLUMN encoding_type INTEGER NOT NULL DEFAULT 0;");

                        return 5;

                } finally {
                        closeStatement(statement);
                }
        }

        private int updateFromSchema5toSchema6(int schemaVersionNumber, CaseDbConnection connection) throws SQLException, TskCoreException {
                if (schemaVersionNumber != 5) {
                        return schemaVersionNumber;
                }

                /*
                 * This upgrade fixes a bug where some releases had artifact review
                 * status support in the case database and others did not.
                 */
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        /*
                         * Add the review_statuses lookup table, if missing.
                         */
                        statement = connection.createStatement();
                        statement.execute("CREATE TABLE IF NOT EXISTS review_statuses (review_status_id INTEGER PRIMARY KEY, review_status_name TEXT NOT NULL, display_name TEXT NOT NULL)");

                        resultSet = connection.executeQuery(statement, "SELECT COUNT(*) AS count FROM review_statuses"); //NON-NLS
                        resultSet.next();
                        if (resultSet.getLong("count") == 0) {
                                /*
                                 * Add review_status_id column to artifacts table.
                                 *
                                 * NOTE: For DBs created with schema 5 or 6 we define a foreign
                                 * key constraint on the review_status_column. We don't bother
                                 * with this for DBs updated to schema 5 or 6 because of
                                 * limitations of the SQLite ALTER TABLE command.
                                 */
                                statement.execute("ALTER TABLE blackboard_artifacts ADD COLUMN review_status_id INTEGER NOT NULL DEFAULT " + BlackboardArtifact.ReviewStatus.UNDECIDED.getID());
                        }

                        return 6;

                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                }
        }

        public int getSchemaVersion() {
                return this.versionNumber;
        }

        public DbType getDatabaseType() {
                return this.dbType;
        }

        public String getBackupDatabasePath() {
                return dbBackupPath;
        }

        public CaseDbTransaction beginTransaction() throws TskCoreException {
                return new CaseDbTransaction(connections.getConnection());
        }

        public String getDatabaseName() {
                return databaseName;
        }

        public String getDbDirPath() {
                return caseDirPath;
        }

        public void acquireExclusiveLock() {
                if (dbType == DbType.SQLITE) {
                        rwLock.writeLock().lock();
                }
        }

        public void releaseExclusiveLock() {
                if (dbType == DbType.SQLITE) {
                        rwLock.writeLock().unlock();
                }
        }

        public void acquireSharedLock() {
                if (dbType == DbType.SQLITE) {
                        rwLock.readLock().lock();
                }
        }

        public void releaseSharedLock() {
                if (dbType == DbType.SQLITE) {
                        rwLock.readLock().unlock();
                }
        }

        public static SleuthkitCase openCase(String dbPath) throws TskCoreException {
                try {
                        final SleuthkitJNI.CaseDbHandle caseHandle = SleuthkitJNI.openCaseDb(dbPath);
                        return new SleuthkitCase(dbPath, caseHandle, DbType.SQLITE);
                } catch (Exception ex) {
                        throw new TskCoreException("Failed to open case database at " + dbPath, ex);
                }
        }

        public static SleuthkitCase openCase(String databaseName, CaseDbConnectionInfo info, String caseDir) throws TskCoreException {
                try {
                        /*
                         * The flow of this method involves trying to open case and if
                         * successful, return that case. If unsuccessful, an exception is
                         * thrown. We catch any exceptions, and use tryConnect() to attempt
                         * to obtain further information about the error. If tryConnect() is
                         * unable to successfully connect, tryConnect() will throw a
                         * TskCoreException with a message containing user-level error
                         * reporting. If tryConnect() is able to connect, flow continues and
                         * we rethrow the original exception obtained from trying to create
                         * the case. In this way, we obtain more detailed information if we
                         * are able, but do not lose any information if unable.
                         */
                        final SleuthkitJNI.CaseDbHandle caseHandle = SleuthkitJNI.openCaseDb(databaseName, info);
                        return new SleuthkitCase(info.getHost(), Integer.parseInt(info.getPort()), databaseName, info.getUserName(), info.getPassword(), caseHandle, caseDir, info.getDbType());
                } catch (PropertyVetoException exp) {
                        // In this case, the JDBC driver doesn't support PostgreSQL. Use the generic message here.
                        throw new TskCoreException(exp.getMessage(), exp);
                } catch (Exception exp) {
                        tryConnect(info); // attempt to connect, throw with user-friendly message if unable
                        throw new TskCoreException(exp.getMessage(), exp); // throw with generic message if tryConnect() was successful
                }
        }

        public static SleuthkitCase newCase(String dbPath) throws TskCoreException {
                try {
                        SleuthkitJNI.CaseDbHandle caseHandle = SleuthkitJNI.newCaseDb(dbPath);
                        return new SleuthkitCase(dbPath, caseHandle, DbType.SQLITE);
                } catch (Exception ex) {
                        throw new TskCoreException("Failed to create case database at " + dbPath, ex);
                }
        }

        public static SleuthkitCase newCase(String caseName, CaseDbConnectionInfo info, String caseDirPath) throws TskCoreException {
                String databaseName = createCaseDataBaseName(caseName);
                try {
                        SleuthkitJNI.CaseDbHandle caseHandle = SleuthkitJNI.newCaseDb(databaseName, info);
                        return new SleuthkitCase(info.getHost(), Integer.parseInt(info.getPort()),
                                        databaseName, info.getUserName(), info.getPassword(), caseHandle, caseDirPath, info.getDbType());
                } catch (PropertyVetoException exp) {
                        // In this case, the JDBC driver doesn't support PostgreSQL. Use the generic message here.
                        throw new TskCoreException(exp.getMessage(), exp);
                } catch (Exception exp) {
                        tryConnect(info); // attempt to connect, throw with user-friendly message if unable
                        throw new TskCoreException(exp.getMessage(), exp); // throw with generic message if tryConnect() was successful
                }
        }

        private static String createCaseDataBaseName(String candidateDbName) {
                String dbName;
                if (!candidateDbName.isEmpty()) {
                        /*
                         * Replace all non-ASCII characters.
                         */
                        dbName = candidateDbName.replaceAll("[^\\p{ASCII}]", "_"); //NON-NLS

                        /*
                         * Replace all control characters.
                         */
                        dbName = dbName.replaceAll("[\\p{Cntrl}]", "_"); //NON-NLS

                        /*
                         * Replace /, \, :, ?, space, ' ".
                         */
                        dbName = dbName.replaceAll("[ /?:'\"\\\\]", "_"); //NON-NLS

                        /*
                         * Make it all lowercase.
                         */
                        dbName = dbName.toLowerCase();

                        /*
                         * Must start with letter or underscore. If not, prepend an
                         * underscore.
                         */
                        if ((dbName.length() > 0 && !(Character.isLetter(dbName.codePointAt(0))) && !(dbName.codePointAt(0) == '_'))) {
                                dbName = "_" + dbName;
                        }

                        /*
                         * Truncate to 63 - 16 = 47 chars to accomodate a timestamp for
                         * uniqueness.
                         */
                        if (dbName.length() > MAX_DB_NAME_LEN_BEFORE_TIMESTAMP) {
                                dbName = dbName.substring(0, MAX_DB_NAME_LEN_BEFORE_TIMESTAMP);
                        }

                } else {
                        /*
                         * Must start with letter or underscore.
                         */
                        dbName = "_";
                }
                /*
                 * Add the time stmap.
                 */
                SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd_HHmmss");
                Date date = new Date();
                dbName = dbName + "_" + dateFormat.format(date);

                return dbName;
        }

        public AddImageProcess makeAddImageProcess(String timezone, boolean addUnallocSpace, boolean noFatFsOrphans,
                        String imageWriterPath) {
                return this.caseHandle.initAddImageProcess(timezone, addUnallocSpace, noFatFsOrphans, imageWriterPath);
        }

        public List<Content> getRootObjects() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT obj_id, type FROM tsk_objects " //NON-NLS
                                        + "WHERE par_obj_id IS NULL"); //NON-NLS
                        Collection<ObjectInfo> infos = new ArrayList<ObjectInfo>();
                        while (rs.next()) {
                                infos.add(new ObjectInfo(rs.getLong("obj_id"), ObjectType.valueOf(rs.getShort("type")))); //NON-NLS
                        }

                        List<Content> rootObjs = new ArrayList<Content>();
                        for (ObjectInfo i : infos) {
                                if (null != i.type) {
                                        switch (i.type) {
                                                case IMG:
                                                        rootObjs.add(getImageById(i.id));
                                                        break;
                                                case ABSTRACTFILE:
                                                        // Check if virtual dir for local files.
                                                        AbstractFile af = getAbstractFileById(i.id);
                                                        if (af instanceof VirtualDirectory) {
                                                                rootObjs.add(af);
                                                        } else {
                                                                throw new TskCoreException("Parentless object has wrong type to be a root (ABSTRACTFILE, but not VIRTUAL_DIRECTORY: " + i.type);
                                                        }
                                                        break;
                                                default:
                                                        throw new TskCoreException("Parentless object has wrong type to be a root: " + i.type);
                                        }
                                }
                        }
                        return rootObjs;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting root objects", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<DataSource> getDataSources() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT obj_id, device_id, time_zone FROM data_source_info"); //NON-NLS
                        List<DataSource> dataSources = new ArrayList<DataSource>();
                        while (rs.next()) {
                                dataSources.add(new AbstractDataSource(rs.getLong("obj_id"), rs.getString("device_id"), rs.getString("time_zone")));
                        }
                        return dataSources;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting data sources", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public DataSource getDataSource(long objectId) throws TskDataException, TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT device_id, time_zone FROM data_source_info WHERE obj_id = " + objectId); //NON-NLS
                        if (rs.next()) {
                                return new AbstractDataSource(objectId, rs.getString("device_id"), rs.getString("time_zone"));
                        } else {
                                throw new TskDataException(String.format("There is no data source with obj_id = %d", objectId));
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException(String.format("Error getting data source with obj_id = %d", objectId), ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public ArrayList<BlackboardArtifact> getBlackboardArtifacts(int artifactTypeID) throws TskCoreException {
                return getArtifactsHelper("blackboard_artifacts.artifact_type_id = " + artifactTypeID);
        }

        public long getBlackboardArtifactsCount(long objId) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        // SELECT COUNT(*) AS count FROM blackboard_artifacts WHERE obj_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.COUNT_ARTIFACTS_FROM_SOURCE);
                        statement.clearParameters();
                        statement.setLong(1, objId);
                        rs = connection.executeQuery(statement);
                        long count = 0;
                        if (rs.next()) {
                                count = rs.getLong("count");
                        }
                        return count;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting number of blackboard artifacts by content", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public long getBlackboardArtifactsTypeCount(int artifactTypeID) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        // SELECT COUNT(*) AS count FROM blackboard_artifacts WHERE artifact_type_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.COUNT_ARTIFACTS_OF_TYPE);
                        statement.clearParameters();
                        statement.setInt(1, artifactTypeID);
                        rs = connection.executeQuery(statement);
                        long count = 0;
                        if (rs.next()) {
                                count = rs.getLong("count");
                        }
                        return count;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting number of blackboard artifacts by type", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifact> getBlackboardArtifacts(BlackboardAttribute.ATTRIBUTE_TYPE attrType, String value) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT DISTINCT arts.artifact_id AS artifact_id, " //NON-NLS
                                        + "arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, "
                                        + "types.type_name AS type_name, types.display_name AS display_name, "//NON-NLS
                                        + " arts.review_status_id AS review_status_id " //NON-NLS
                                        + "FROM blackboard_artifacts AS arts, blackboard_attributes AS attrs, blackboard_artifact_types AS types " //NON-NLS
                                        + "WHERE arts.artifact_id = attrs.artifact_id " //NON-NLS
                                        + " AND attrs.attribute_type_id = " + attrType.getTypeID() //NON-NLS
                                        + " AND attrs.value_text = '" + value + "'"
                                        + " AND types.artifact_type_id=arts.artifact_type_id"
                                        + " AND arts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID());   //NON-NLS
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifacts by attribute", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifact> getBlackboardArtifacts(BlackboardAttribute.ATTRIBUTE_TYPE attrType, String subString, boolean startsWith) throws TskCoreException {
                String valSubStr = "%" + subString; //NON-NLS
                if (startsWith == false) {
                        valSubStr += "%"; //NON-NLS
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT DISTINCT arts.artifact_id AS artifact_id, " //NON-NLS
                                        + " arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, " //NON-NLS
                                        + " types.type_name AS type_name, types.display_name AS display_name, " //NON-NLS
                                        + " arts.review_status_id AS review_status_id " //NON-NLS
                                        + " FROM blackboard_artifacts AS arts, blackboard_attributes AS attrs, blackboard_artifact_types AS types " //NON-NLS
                                        + " WHERE arts.artifact_id = attrs.artifact_id " //NON-NLS
                                        + " AND attrs.attribute_type_id = " + attrType.getTypeID() //NON-NLS
                                        + " AND LOWER(attrs.value_text) LIKE LOWER('" + valSubStr + "')"
                                        + " AND types.artifact_type_id=arts.artifact_type_id "
                                        + " AND arts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID());
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifacts by attribute. " + ex.getMessage(), ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifact> getBlackboardArtifacts(BlackboardAttribute.ATTRIBUTE_TYPE attrType, int value) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT DISTINCT arts.artifact_id AS artifact_id, " //NON-NLS
                                        + " arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, "
                                        + " types.type_name AS type_name, types.display_name AS display_name, "
                                        + " arts.review_status_id AS review_status_id  "//NON-NLS
                                        + " FROM blackboard_artifacts AS arts, blackboard_attributes AS attrs, blackboard_artifact_types AS types " //NON-NLS
                                        + "WHERE arts.artifact_id = attrs.artifact_id " //NON-NLS
                                        + " AND attrs.attribute_type_id = " + attrType.getTypeID() //NON-NLS
                                        + " AND attrs.value_int32 = " + value //NON-NLS
                                        + " AND types.artifact_type_id=arts.artifact_type_id "
                                        + " AND arts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID());
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifacts by attribute", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifact> getBlackboardArtifacts(BlackboardAttribute.ATTRIBUTE_TYPE attrType, long value) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT DISTINCT arts.artifact_id AS artifact_id, " //NON-NLS
                                        + " arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, "
                                        + " types.type_name AS type_name, types.display_name AS display_name, "
                                        + " arts.review_status_id AS review_status_id "//NON-NLS
                                        + " FROM blackboard_artifacts AS arts, blackboard_attributes AS attrs, blackboard_artifact_types AS types " //NON-NLS
                                        + " WHERE arts.artifact_id = attrs.artifact_id " //NON-NLS
                                        + " AND attrs.attribute_type_id = " + attrType.getTypeID() //NON-NLS
                                        + " AND attrs.value_int64 = " + value //NON-NLS
                                        + " AND types.artifact_type_id=arts.artifact_type_id "
                                        + " AND arts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID());
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifacts by attribute. " + ex.getMessage(), ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifact> getBlackboardArtifacts(BlackboardAttribute.ATTRIBUTE_TYPE attrType, double value) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT DISTINCT arts.artifact_id AS artifact_id, " //NON-NLS
                                        + " arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, "
                                        + " types.type_name AS type_name, types.display_name AS display_name, "
                                        + " arts.review_status_id AS review_status_id "//NON-NLS
                                        + " FROM blackboard_artifacts AS arts, blackboard_attributes AS attrs, blackboard_artifact_types AS types " //NON-NLS
                                        + " WHERE arts.artifact_id = attrs.artifact_id " //NON-NLS
                                        + " AND attrs.attribute_type_id = " + attrType.getTypeID() //NON-NLS
                                        + " AND attrs.value_double = " + value //NON-NLS
                                        + " AND types.artifact_type_id=arts.artifact_type_id "
                                        + " AND arts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID());
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifacts by attribute", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifact> getBlackboardArtifacts(BlackboardAttribute.ATTRIBUTE_TYPE attrType, byte value) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT DISTINCT arts.artifact_id AS artifact_id, " //NON-NLS
                                        + " arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, "
                                        + " types.type_name AS type_name, types.display_name AS display_name, "
                                        + " arts.review_status_id AS review_status_id "//NON-NLS
                                        + " FROM blackboard_artifacts AS arts, blackboard_attributes AS attrs, blackboard_artifact_types AS types " //NON-NLS
                                        + " WHERE arts.artifact_id = attrs.artifact_id " //NON-NLS
                                        + " AND attrs.attribute_type_id = " + attrType.getTypeID() //NON-NLS
                                        + " AND attrs.value_byte = " + value //NON-NLS
                                        + " AND types.artifact_type_id=arts.artifact_type_id "
                                        + " AND arts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID());
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifacts by attribute", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public Iterable<BlackboardArtifact.Type> getArtifactTypes() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT artifact_type_id, type_name, display_name FROM blackboard_artifact_types"); //NON-NLS
                        ArrayList<BlackboardArtifact.Type> artifactTypes = new ArrayList<BlackboardArtifact.Type>();
                        while (rs.next()) {
                                artifactTypes.add(new BlackboardArtifact.Type(rs.getInt("artifact_type_id"),
                                                rs.getString("type_name"), rs.getString("display_name")));
                        }
                        return artifactTypes;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting artifact types", ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public ArrayList<BlackboardArtifact.ARTIFACT_TYPE> getBlackboardArtifactTypesInUse() throws TskCoreException {
                String typeIdList = "";
                for (int i = 0; i < BlackboardArtifact.ARTIFACT_TYPE.values().length; ++i) {
                        typeIdList += BlackboardArtifact.ARTIFACT_TYPE.values()[i].getTypeID();
                        if (i < BlackboardArtifact.ARTIFACT_TYPE.values().length - 1) {
                                typeIdList += ", ";
                        }
                }
                String query = "SELECT DISTINCT artifact_type_id FROM blackboard_artifacts "
                                + "WHERE artifact_type_id IN (" + typeIdList + ")";
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, query);
                        ArrayList<BlackboardArtifact.ARTIFACT_TYPE> usedArts = new ArrayList<BlackboardArtifact.ARTIFACT_TYPE>();
                        while (rs.next()) {
                                usedArts.add(ARTIFACT_TYPE.fromID(rs.getInt("artifact_type_id")));
                        }
                        return usedArts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting artifact types in use", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifact.Type> getArtifactTypesInUse() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s,
                                        "SELECT DISTINCT arts.artifact_type_id AS artifact_type_id, "
                                        + "types.type_name AS type_name, types.display_name AS display_name "
                                        + "FROM blackboard_artifact_types AS types "
                                        + "INNER JOIN blackboard_artifacts AS arts "
                                        + "ON arts.artifact_type_id = types.artifact_type_id"); //NON-NLS
                        List<BlackboardArtifact.Type> uniqueArtifactTypes = new ArrayList<BlackboardArtifact.Type>();
                        while (rs.next()) {
                                uniqueArtifactTypes.add(new BlackboardArtifact.Type(rs.getInt("artifact_type_id"),
                                                rs.getString("type_name"), rs.getString("display_name")));
                        }
                        return uniqueArtifactTypes;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attribute types", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardAttribute.Type> getAttributeTypes() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT attribute_type_id, type_name, display_name, value_type FROM blackboard_attribute_types"); //NON-NLS
                        ArrayList<BlackboardAttribute.Type> attribute_types = new ArrayList<BlackboardAttribute.Type>();
                        while (rs.next()) {
                                attribute_types.add(new BlackboardAttribute.Type(rs.getInt("attribute_type_id"), rs.getString("type_name"),
                                                rs.getString("display_name"), TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE.fromType(rs.getLong("value_type"))));
                        }
                        return attribute_types;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attribute types", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public int getBlackboardAttributeTypesCount() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT COUNT(*) AS count FROM blackboard_attribute_types"); //NON-NLS
                        int count = 0;
                        if (rs.next()) {
                                count = rs.getInt("count");
                        }
                        return count;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting number of blackboard artifacts by type", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        private ArrayList<BlackboardArtifact> getArtifactsHelper(String whereClause) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        Statement statement = connection.createStatement();
                        String query = "SELECT blackboard_artifacts.artifact_id AS artifact_id, "
                                        + "blackboard_artifacts.obj_id AS obj_id, "
                                        + "blackboard_artifact_types.artifact_type_id AS artifact_type_id, "
                                        + "blackboard_artifact_types.type_name AS type_name, "
                                        + "blackboard_artifact_types.display_name AS display_name, "
                                        + "blackboard_artifacts.review_status_id AS review_status_id "
                                        + "FROM blackboard_artifacts, blackboard_artifact_types "
                                        + "WHERE blackboard_artifacts.artifact_type_id = blackboard_artifact_types.artifact_type_id "
                                        + " AND blackboard_artifacts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID()
                                        + " AND " + whereClause;
                        rs = connection.executeQuery(statement, query);
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting or creating a blackboard artifact", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        private long getArtifactsCountHelper(int artifactTypeID, long obj_id) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        // SELECT COUNT(*) AS count FROM blackboard_artifacts WHERE obj_id = ? AND artifact_type_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.COUNT_ARTIFACTS_BY_SOURCE_AND_TYPE);
                        statement.clearParameters();
                        statement.setLong(1, obj_id);
                        statement.setInt(2, artifactTypeID);
                        rs = connection.executeQuery(statement);
                        long count = 0;
                        if (rs.next()) {
                                count = rs.getLong("count");
                        }
                        return count;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifact count", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public ArrayList<BlackboardArtifact> getBlackboardArtifacts(String artifactTypeName, long obj_id) throws TskCoreException {
                return getArtifactsHelper("blackboard_artifacts.obj_id = " + obj_id + " AND blackboard_artifact_types.type_name = '" + artifactTypeName + "';");
        }

        public ArrayList<BlackboardArtifact> getBlackboardArtifacts(int artifactTypeID, long obj_id) throws TskCoreException {
                return getArtifactsHelper("blackboard_artifacts.obj_id = " + obj_id + " AND blackboard_artifact_types.artifact_type_id = " + artifactTypeID + ";");
        }

        public ArrayList<BlackboardArtifact> getBlackboardArtifacts(ARTIFACT_TYPE artifactType, long obj_id) throws TskCoreException {
                return getBlackboardArtifacts(artifactType.getTypeID(), obj_id);
        }

        public long getBlackboardArtifactsCount(String artifactTypeName, long obj_id) throws TskCoreException {
                int artifactTypeID = this.getArtifactType(artifactTypeName).getTypeID();
                if (artifactTypeID == -1) {
                        return 0;
                }
                return getArtifactsCountHelper(artifactTypeID, obj_id);
        }

        public long getBlackboardArtifactsCount(int artifactTypeID, long obj_id) throws TskCoreException {
                return getArtifactsCountHelper(artifactTypeID, obj_id);
        }

        public long getBlackboardArtifactsCount(ARTIFACT_TYPE artifactType, long obj_id) throws TskCoreException {
                return getArtifactsCountHelper(artifactType.getTypeID(), obj_id);
        }

        public ArrayList<BlackboardArtifact> getBlackboardArtifacts(String artifactTypeName) throws TskCoreException {
                return getArtifactsHelper("blackboard_artifact_types.type_name = '" + artifactTypeName + "';");
        }

        public ArrayList<BlackboardArtifact> getBlackboardArtifacts(ARTIFACT_TYPE artifactType) throws TskCoreException {
                return getArtifactsHelper("blackboard_artifact_types.artifact_type_id = " + artifactType.getTypeID() + ";");
        }

        public List<BlackboardArtifact> getBlackboardArtifacts(ARTIFACT_TYPE artifactType, BlackboardAttribute.ATTRIBUTE_TYPE attrType, String value) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT DISTINCT arts.artifact_id AS artifact_id, " //NON-NLS
                                        + "arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, "
                                        + "types.type_name AS type_name, types.display_name AS display_name,"
                                        + "arts.review_status_id AS review_status_id "//NON-NLS
                                        + "FROM blackboard_artifacts AS arts, blackboard_attributes AS attrs, blackboard_artifact_types AS types " //NON-NLS
                                        + "WHERE arts.artifact_id = attrs.artifact_id " //NON-NLS
                                        + "AND attrs.attribute_type_id = " + attrType.getTypeID() //NON-NLS
                                        + " AND arts.artifact_type_id = " + artifactType.getTypeID() //NON-NLS
                                        + " AND attrs.value_text = '" + value + "'" //NON-NLS
                                        + " AND types.artifact_type_id=arts.artifact_type_id"
                                        + " AND arts.review_status_id !=" + BlackboardArtifact.ReviewStatus.REJECTED.getID());
                        ArrayList<BlackboardArtifact> artifacts = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                artifacts.add(new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id"))));
                        }
                        return artifacts;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifacts by artifact type and attribute. " + ex.getMessage(), ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public BlackboardArtifact getBlackboardArtifact(long artifactID) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                Statement s = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT arts.artifact_id AS artifact_id, "
                                        + "arts.obj_id AS obj_id, arts.artifact_type_id AS artifact_type_id, "
                                        + "types.type_name AS type_name, types.display_name AS display_name,"
                                        + "arts.review_status_id AS review_status_id "//NON-NLS
                                        + "FROM blackboard_artifacts AS arts, blackboard_artifact_types AS types "
                                        + "WHERE arts.artifact_id = " + artifactID
                                        + " AND arts.artifact_type_id = types.artifact_type_id");
                        if (rs.next()) {
                                return new BlackboardArtifact(this, rs.getLong("artifact_id"), rs.getLong("obj_id"),
                                                rs.getInt("artifact_type_id"), rs.getString("type_name"), rs.getString("display_name"),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id")));
                        } else {
                                /*
                                 * I think this should actually return null (or Optional) when
                                 * there is no artifact with the given id, but it looks like
                                 * existing code is not expecting that. -jm
                                 */
                                throw new TskCoreException("No blackboard artifact with id " + artifactID);
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting a blackboard artifact. " + ex.getMessage(), ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public void addBlackboardAttribute(BlackboardAttribute attr, int artifactTypeId) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                try {
                        addBlackBoardAttribute(attr, artifactTypeId, connection);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error adding blackboard attribute " + attr.toString(), ex);
                } finally {
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public void addBlackboardAttributes(Collection<BlackboardAttribute> attributes, int artifactTypeId) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                try {
                        connection.beginTransaction();
                        for (final BlackboardAttribute attr : attributes) {
                                addBlackBoardAttribute(attr, artifactTypeId, connection);
                        }
                        connection.commitTransaction();
                } catch (SQLException ex) {
                        connection.rollbackTransaction();
                        throw new TskCoreException("Error adding blackboard attributes", ex);
                } finally {
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        private void addBlackBoardAttribute(BlackboardAttribute attr, int artifactTypeId, CaseDbConnection connection) throws SQLException, TskCoreException {
                PreparedStatement statement;
                switch (attr.getAttributeType().getValueType()) {
                        case STRING:
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_STRING_ATTRIBUTE);
                                statement.clearParameters();
                                statement.setString(7, attr.getValueString());
                                break;
                        case BYTE:
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_BYTE_ATTRIBUTE);
                                statement.clearParameters();
                                statement.setBytes(7, attr.getValueBytes());
                                break;
                        case INTEGER:
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_INT_ATTRIBUTE);
                                statement.clearParameters();
                                statement.setInt(7, attr.getValueInt());
                                break;
                        case LONG:
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_LONG_ATTRIBUTE);
                                statement.clearParameters();
                                statement.setLong(7, attr.getValueLong());
                                break;
                        case DOUBLE:
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_DOUBLE_ATTRIBUTE);
                                statement.clearParameters();
                                statement.setDouble(7, attr.getValueDouble());
                                break;
                        case DATETIME:
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_LONG_ATTRIBUTE);
                                statement.clearParameters();
                                statement.setLong(7, attr.getValueLong());
                                break;
                        default:
                                throw new TskCoreException("Unrecognized artifact attribute value type");
                }
                statement.setLong(1, attr.getArtifactID());
                statement.setInt(2, artifactTypeId);
                statement.setString(3, attr.getSourcesCSV());
                statement.setString(4, "");
                statement.setInt(5, attr.getAttributeType().getTypeID());
                statement.setLong(6, attr.getAttributeType().getValueType().getType());
                connection.executeUpdate(statement);
        }

        String addSourceToArtifactAttribute(BlackboardAttribute attr, String source) throws TskCoreException {
                /*
                 * WARNING: This is a temporary implementation that is not safe and
                 * denormalizes the case datbase.
                 *
                 * TODO (JIRA-2294): Provide a safe and normalized solution to tracking
                 * the sources of artifact attributes.
                 */
                if (null == source || source.isEmpty()) {
                        throw new TskCoreException("Attempt to add null or empty source module name to artifact attribute");
                }
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                Statement queryStmt = null;
                Statement updateStmt = null;
                ResultSet result = null;
                String newSources = "";
                try {
                        connection.beginTransaction();
                        String valueClause = "";
                        BlackboardAttribute.TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE valueType = attr.getAttributeType().getValueType();
                        if (BlackboardAttribute.TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE.BYTE != valueType) {
                                switch (valueType) {
                                        case STRING:
                                                valueClause = " value_text = '" + escapeSingleQuotes(attr.getValueString()) + "'";
                                                break;
                                        case INTEGER:
                                                valueClause = " value_int32 = " + attr.getValueInt();
                                                break;
                                        case LONG:
                                        case DATETIME:
                                                valueClause = " value_int64 = " + attr.getValueLong();
                                                break;
                                        case DOUBLE:
                                                valueClause = " value_double = " + attr.getValueDouble();
                                                break;
                                        default:
                                                throw new TskCoreException(String.format("Unrecognized value type for attribute %s", attr.getDisplayString()));
                                }
                                String query = "SELECT source FROM blackboard_attributes WHERE"
                                                + " artifact_id = " + attr.getArtifactID()
                                                + " AND attribute_type_id = " + attr.getAttributeType().getTypeID()
                                                + " AND value_type = " + attr.getAttributeType().getValueType().getType()
                                                + " AND " + valueClause + ";";
                                queryStmt = connection.createStatement();
                                updateStmt = connection.createStatement();
                                result = connection.executeQuery(queryStmt, query);
                        } else {
                                /*
                                 * SELECT source FROM blackboard_attributes WHERE artifact_id =
                                 * ? AND attribute_type_id = ? AND value_type = 4 AND value_byte
                                 * = ?
                                 */
                                PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_ATTR_BY_VALUE_BYTE);
                                statement.clearParameters();
                                statement.setLong(1, attr.getArtifactID());
                                statement.setLong(2, attr.getAttributeType().getTypeID());
                                statement.setBytes(3, attr.getValueBytes());
                                result = connection.executeQuery(statement);
                        }
                        while (result.next()) {
                                String oldSources = result.getString("source");
                                if (null != oldSources && !oldSources.isEmpty()) {
                                        Set<String> uniqueSources = new HashSet<String>(Arrays.asList(oldSources.split(",")));
                                        if (!uniqueSources.contains(source)) {
                                                newSources = oldSources + "," + source;
                                        } else {
                                                newSources = oldSources;
                                        }
                                } else {
                                        newSources = source;
                                }
                                if (BlackboardAttribute.TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE.BYTE != valueType) {
                                        String update = "UPDATE blackboard_attributes SET source = '" + newSources + "' WHERE"
                                                        + " artifact_id = " + attr.getArtifactID()
                                                        + " AND attribute_type_id = " + attr.getAttributeType().getTypeID()
                                                        + " AND value_type = " + attr.getAttributeType().getValueType().getType()
                                                        + " AND " + valueClause + ";";
                                        connection.executeUpdate(updateStmt, update);
                                } else {
                                        /*
                                         * UPDATE blackboard_attributes SET source = ? WHERE
                                         * artifact_id = ? AND attribute_type_id = ? AND value_type
                                         * = 4 AND value_byte = ?
                                         */
                                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.UPDATE_ATTR_BY_VALUE_BYTE);
                                        statement.clearParameters();
                                        statement.setString(1, newSources);
                                        statement.setLong(2, attr.getArtifactID());
                                        statement.setLong(3, attr.getAttributeType().getTypeID());
                                        statement.setBytes(4, attr.getValueBytes());
                                        connection.executeUpdate(statement);
                                }
                        }
                        connection.commitTransaction();
                        return newSources;
                } catch (SQLException ex) {
                        connection.rollbackTransaction();
                        throw new TskCoreException(String.format("Error adding source module to attribute %s", attr.getDisplayString()), ex);
                } finally {
                        closeResultSet(result);
                        closeStatement(updateStmt);
                        closeStatement(queryStmt);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public BlackboardAttribute.Type addArtifactAttributeType(String attrTypeString, TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE valueType, String displayName) throws TskCoreException, TskDataException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        connection.beginTransaction();
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT attribute_type_id FROM blackboard_attribute_types WHERE type_name = '" + attrTypeString + "'"); //NON-NLS
                        if (!rs.next()) {
                                rs.close();
                                rs = connection.executeQuery(s, "SELECT MAX(attribute_type_id) AS highest_id FROM blackboard_attribute_types");
                                int maxID = 0;
                                if (rs.next()) {
                                        maxID = rs.getInt("highest_id");
                                        if (maxID < MIN_USER_DEFINED_TYPE_ID) {
                                                maxID = MIN_USER_DEFINED_TYPE_ID;
                                        } else {
                                                maxID++;
                                        }
                                }
                                connection.executeUpdate(s, "INSERT INTO blackboard_attribute_types (attribute_type_id, type_name, display_name, value_type) VALUES ('" + maxID + "', '" + attrTypeString + "', '" + displayName + "', '" + valueType.getType() + "')"); //NON-NLS
                                BlackboardAttribute.Type type = new BlackboardAttribute.Type(maxID, attrTypeString, displayName, valueType);
                                this.typeIdToAttributeTypeMap.put(type.getTypeID(), type);
                                this.typeNameToAttributeTypeMap.put(type.getTypeName(), type);
                                connection.commitTransaction();
                                return type;
                        } else {
                                throw new TskDataException("The attribute type that was added was already within the system.");
                        }

                } catch (SQLException ex) {
                        connection.rollbackTransaction();
                        throw new TskCoreException("Error adding attribute type", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public BlackboardAttribute.Type getAttributeType(String attrTypeName) throws TskCoreException {
                if (this.typeNameToAttributeTypeMap.containsKey(attrTypeName)) {
                        return this.typeNameToAttributeTypeMap.get(attrTypeName);
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT attribute_type_id, type_name, display_name, value_type FROM blackboard_attribute_types WHERE type_name = '" + attrTypeName + "'"); //NON-NLS
                        BlackboardAttribute.Type type = null;
                        if (rs.next()) {
                                type = new BlackboardAttribute.Type(rs.getInt("attribute_type_id"), rs.getString("type_name"),
                                                rs.getString("display_name"), TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE.fromType(rs.getLong("value_type")));
                                this.typeIdToAttributeTypeMap.put(type.getTypeID(), type);
                                this.typeNameToAttributeTypeMap.put(attrTypeName, type);
                        }
                        return type;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attribute type id", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        private BlackboardAttribute.Type getAttributeType(int typeID) throws TskCoreException {
                if (this.typeIdToAttributeTypeMap.containsKey(typeID)) {
                        return this.typeIdToAttributeTypeMap.get(typeID);
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT attribute_type_id, type_name, display_name, value_type FROM blackboard_attribute_types WHERE attribute_type_id = " + typeID + ""); //NON-NLS
                        BlackboardAttribute.Type type = null;
                        if (rs.next()) {
                                type = new BlackboardAttribute.Type(rs.getInt("attribute_type_id"), rs.getString("type_name"),
                                                rs.getString("display_name"), TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE.fromType(rs.getLong("value_type")));
                                this.typeIdToAttributeTypeMap.put(typeID, type);
                                this.typeNameToAttributeTypeMap.put(type.getTypeName(), type);
                        }
                        return type;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attribute type id", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public BlackboardArtifact.Type getArtifactType(String artTypeName) throws TskCoreException {
                if (this.typeNameToArtifactTypeMap.containsKey(artTypeName)) {
                        return this.typeNameToArtifactTypeMap.get(artTypeName);
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT artifact_type_id, type_name, display_name FROM blackboard_artifact_types WHERE type_name = '" + artTypeName + "'"); //NON-NLS
                        BlackboardArtifact.Type type = null;
                        if (rs.next()) {
                                type = new BlackboardArtifact.Type(rs.getInt("artifact_type_id"),
                                                rs.getString("type_name"), rs.getString("display_name"));
                                this.typeIdToArtifactTypeMap.put(type.getTypeID(), type);
                                this.typeNameToArtifactTypeMap.put(artTypeName, type);
                        }
                        return type;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting artifact type from the database", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        BlackboardArtifact.Type getArtifactType(int artTypeId) throws TskCoreException {
                if (this.typeIdToArtifactTypeMap.containsKey(artTypeId)) {
                        return typeIdToArtifactTypeMap.get(artTypeId);
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT artifact_type_id, type_name, display_name FROM blackboard_artifact_types WHERE artifact_type_id = " + artTypeId + ""); //NON-NLS
                        BlackboardArtifact.Type type = null;
                        if (rs.next()) {
                                type = new BlackboardArtifact.Type(rs.getInt("artifact_type_id"),
                                                rs.getString("type_name"), rs.getString("display_name"));
                                this.typeIdToArtifactTypeMap.put(artTypeId, type);
                                this.typeNameToArtifactTypeMap.put(type.getTypeName(), type);
                        }
                        return type;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting artifact type from the database", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public BlackboardArtifact.Type addBlackboardArtifactType(String artifactTypeName, String displayName) throws TskCoreException, TskDataException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        connection.beginTransaction();
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT artifact_type_id FROM blackboard_artifact_types WHERE type_name = '" + artifactTypeName + "'"); //NON-NLS
                        if (!rs.next()) {
                                rs.close();
                                rs = connection.executeQuery(s, "SELECT MAX(artifact_type_id) AS highest_id FROM blackboard_artifact_types");
                                int maxID = 0;
                                if (rs.next()) {
                                        maxID = rs.getInt("highest_id");
                                        if (maxID < MIN_USER_DEFINED_TYPE_ID) {
                                                maxID = MIN_USER_DEFINED_TYPE_ID;
                                        } else {
                                                maxID++;
                                        }
                                }
                                connection.executeUpdate(s, "INSERT INTO blackboard_artifact_types (artifact_type_id, type_name, display_name) VALUES ('" + maxID + "', '" + artifactTypeName + "', '" + displayName + "')"); //NON-NLS
                                BlackboardArtifact.Type type = new BlackboardArtifact.Type(maxID, artifactTypeName, displayName);
                                this.typeIdToArtifactTypeMap.put(type.getTypeID(), type);
                                this.typeNameToArtifactTypeMap.put(type.getTypeName(), type);
                                connection.commitTransaction();
                                return type;
                        } else {
                                throw new TskDataException("The attribute type that was added was already within the system.");
                        }
                } catch (SQLException ex) {
                        connection.rollbackTransaction();
                        throw new TskCoreException("Error adding artifact type", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public ArrayList<BlackboardAttribute> getBlackboardAttributes(final BlackboardArtifact artifact) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        Statement statement = connection.createStatement();
                        rs = connection.executeQuery(statement, "SELECT attrs.artifact_id AS artifact_id, "
                                        + "attrs.source AS source, attrs.context AS context, attrs.attribute_type_id AS attribute_type_id, "
                                        + "attrs.value_type AS value_type, attrs.value_byte AS value_byte, "
                                        + "attrs.value_text AS value_text, attrs.value_int32 AS value_int32, "
                                        + "attrs.value_int64 AS value_int64, attrs.value_double AS value_double, "
                                        + "types.type_name AS type_name, types.display_name AS display_name "
                                        + "FROM blackboard_attributes AS attrs, blackboard_attribute_types AS types WHERE attrs.artifact_id = " + artifact.getArtifactID()
                                        + " AND attrs.attribute_type_id = types.attribute_type_id");
                        ArrayList<BlackboardAttribute> attributes = new ArrayList<BlackboardAttribute>();
                        while (rs.next()) {
                                final BlackboardAttribute attr = new BlackboardAttribute(
                                                rs.getLong("artifact_id"),
                                                new BlackboardAttribute.Type(rs.getInt("attribute_type_id"), rs.getString("type_name"),
                                                                rs.getString("display_name"), BlackboardAttribute.TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE.fromType(rs.getInt("value_type"))),
                                                rs.getString("source"),
                                                rs.getString("context"),
                                                rs.getInt("value_int32"),
                                                rs.getLong("value_int64"),
                                                rs.getDouble("value_double"),
                                                rs.getString("value_text"),
                                                rs.getBytes("value_byte"), this
                                );
                                attributes.add(attr);
                        }
                        return attributes;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attributes for artifact, artifact id = " + artifact.getArtifactID(), ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public ArrayList<BlackboardAttribute> getMatchingAttributes(String whereClause) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT blackboard_attributes.artifact_id AS artifact_id, "
                                        + "blackboard_attributes.source AS source, blackboard_attributes.context AS context, "
                                        + "blackboard_attributes.attribute_type_id AS attribute_type_id, "
                                        + "blackboard_attributes.value_type AS value_type, blackboard_attributes.value_byte AS value_byte, "
                                        + "blackboard_attributes.value_text AS value_text, blackboard_attributes.value_int32 AS value_int32, "
                                        + "blackboard_attributes.value_int64 AS value_int64, blackboard_attributes.value_double AS value_double "
                                        + "FROM blackboard_attributes " + whereClause); //NON-NLS
                        ArrayList<BlackboardAttribute> matches = new ArrayList<BlackboardAttribute>();
                        while (rs.next()) {
                                BlackboardAttribute.Type type;
                                // attribute type is cached, so this does not necessarily call to the db
                                type = this.getAttributeType(rs.getInt("attribute_type_id"));
                                BlackboardAttribute attr = new BlackboardAttribute(
                                                rs.getLong("artifact_id"),
                                                type,
                                                rs.getString("source"),
                                                rs.getString("context"),
                                                rs.getInt("value_int32"),
                                                rs.getLong("value_int64"),
                                                rs.getDouble("value_double"),
                                                rs.getString("value_text"),
                                                rs.getBytes("value_byte"), this
                                );
                                matches.add(attr);
                        }
                        return matches;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attributes using this where clause: " + whereClause, ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public ArrayList<BlackboardArtifact> getMatchingArtifacts(String whereClause) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                Statement s = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT blackboard_artifacts.artifact_id AS artifact_id, "
                                        + "blackboard_artifacts.obj_id AS obj_id, blackboard_artifacts.artifact_type_id AS artifact_type_id, "
                                        + "blackboard_artifacts.review_status_id AS review_status_id  "
                                        + "FROM blackboard_artifacts " + whereClause); //NON-NLS
                        ArrayList<BlackboardArtifact> matches = new ArrayList<BlackboardArtifact>();
                        while (rs.next()) {
                                BlackboardArtifact.Type type;
                                // artifact type is cached, so this does not necessarily call to the db
                                type = this.getArtifactType(rs.getInt("artifact_type_id"));
                                BlackboardArtifact artifact = new BlackboardArtifact(this, rs.getLong("artifact_id"),
                                                rs.getLong("obj_id"), type.getTypeID(), type.getTypeName(), type.getDisplayName(),
                                                BlackboardArtifact.ReviewStatus.withID(rs.getInt("review_status_id")));
                                matches.add(artifact);
                        }
                        return matches;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attributes using this where clause: " + whereClause, ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public BlackboardArtifact newBlackboardArtifact(int artifactTypeID, long obj_id) throws TskCoreException {
                BlackboardArtifact.Type type = getArtifactType(artifactTypeID);
                return newBlackboardArtifact(artifactTypeID, obj_id, type.getTypeName(), type.getDisplayName());
        }

        public BlackboardArtifact newBlackboardArtifact(ARTIFACT_TYPE artifactType, long obj_id) throws TskCoreException {
                return newBlackboardArtifact(artifactType.getTypeID(), obj_id, artifactType.getLabel(), artifactType.getDisplayName());
        }

        private BlackboardArtifact newBlackboardArtifact(int artifact_type_id, long obj_id, String artifactTypeName, String artifactDisplayName) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement;
                        if (dbType == DbType.POSTGRESQL) {
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.POSTGRESQL_INSERT_ARTIFACT, Statement.RETURN_GENERATED_KEYS);
                                statement.clearParameters();
                                statement.setLong(1, obj_id);
                                statement.setInt(2, artifact_type_id);
                        } else {
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_ARTIFACT, Statement.RETURN_GENERATED_KEYS);
                                statement.clearParameters();
                                this.nextArtifactId++;
                                statement.setLong(1, this.nextArtifactId);
                                statement.setLong(2, obj_id);
                                statement.setInt(3, artifact_type_id);
                        }
                        connection.executeUpdate(statement);
                        rs = statement.getGeneratedKeys();
                        rs.next();
                        return new BlackboardArtifact(this, rs.getLong(1), //last_insert_rowid()
                                        obj_id, artifact_type_id, artifactTypeName, artifactDisplayName, BlackboardArtifact.ReviewStatus.UNDECIDED, true);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error creating a blackboard artifact", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        boolean getContentHasChildren(Content content) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        // SELECT COUNT(obj_id) AS count FROM tsk_objects WHERE par_obj_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.COUNT_CHILD_OBJECTS_BY_PARENT);
                        statement.clearParameters();
                        statement.setLong(1, content.getId());
                        rs = connection.executeQuery(statement);
                        boolean hasChildren = false;
                        if (rs.next()) {
                                hasChildren = rs.getInt("count") > 0;
                        }
                        return hasChildren;
                } catch (SQLException e) {
                        throw new TskCoreException("Error checking for children of parent " + content, e);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        int getContentChildrenCount(Content content) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        // SELECT COUNT(obj_id) AS count FROM tsk_objects WHERE par_obj_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.COUNT_CHILD_OBJECTS_BY_PARENT);
                        statement.clearParameters();
                        statement.setLong(1, content.getId());
                        rs = connection.executeQuery(statement);
                        int countChildren = -1;
                        if (rs.next()) {
                                countChildren = rs.getInt("count");
                        }
                        return countChildren;
                } catch (SQLException e) {
                        throw new TskCoreException("Error checking for children of parent " + content, e);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        List<Content> getAbstractFileChildren(Content parent, TSK_DB_FILES_TYPE_ENUM type) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILES_BY_PARENT_AND_TYPE);
                        statement.clearParameters();
                        long parentId = parent.getId();
                        statement.setLong(1, parentId);
                        statement.setShort(2, type.getFileType());
                        rs = connection.executeQuery(statement);
                        return fileChildren(rs, connection, parentId);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting AbstractFile children for Content", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        List<Content> getAbstractFileChildren(Content parent) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILES_BY_PARENT);
                        statement.clearParameters();
                        long parentId = parent.getId();
                        statement.setLong(1, parentId);
                        rs = connection.executeQuery(statement);
                        return fileChildren(rs, connection, parentId);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting AbstractFile children for Content", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        List<Long> getAbstractFileChildrenIds(Content parent, TSK_DB_FILES_TYPE_ENUM type) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILE_IDS_BY_PARENT_AND_TYPE);
                        statement.clearParameters();
                        statement.setLong(1, parent.getId());
                        statement.setShort(2, type.getFileType());
                        rs = connection.executeQuery(statement);
                        List<Long> children = new ArrayList<Long>();
                        while (rs.next()) {
                                children.add(rs.getLong("obj_id"));
                        }
                        return children;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting AbstractFile children for Content", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        List<Long> getAbstractFileChildrenIds(Content parent) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILE_IDS_BY_PARENT);
                        statement.clearParameters();
                        statement.setLong(1, parent.getId());
                        rs = connection.executeQuery(statement);
                        List<Long> children = new ArrayList<Long>();
                        while (rs.next()) {
                                children.add(rs.getLong("obj_id"));
                        }
                        return children;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting AbstractFile children for Content", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        Collection<ObjectInfo> getChildrenInfo(Content c) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT tsk_objects.obj_id AS obj_id, tsk_objects.type AS type " //NON-NLS
                                        + "FROM tsk_objects LEFT JOIN tsk_files " //NON-NLS
                                        + "ON tsk_objects.obj_id = tsk_files.obj_id " //NON-NLS
                                        + "WHERE tsk_objects.par_obj_id = " + c.getId()
                                        + " ORDER BY tsk_objects.obj_id"); //NON-NLS
                        Collection<ObjectInfo> infos = new ArrayList<ObjectInfo>();
                        while (rs.next()) {
                                infos.add(new ObjectInfo(rs.getLong("obj_id"), ObjectType.valueOf(rs.getShort("type")))); //NON-NLS
                        }
                        return infos;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Children Info for Content", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        ObjectInfo getParentInfo(Content c) throws TskCoreException {
                // TODO: This should not throw an exception if Content has no parent,
                // return null instead.
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT parent.obj_id AS obj_id, parent.type AS type " //NON-NLS
                                        + "FROM tsk_objects AS parent INNER JOIN tsk_objects AS child " //NON-NLS
                                        + "ON child.par_obj_id = parent.obj_id " //NON-NLS
                                        + "WHERE child.obj_id = " + c.getId()); //NON-NLS
                        if (rs.next()) {
                                return new ObjectInfo(rs.getLong("obj_id"), ObjectType.valueOf(rs.getShort("type")));
                        } else {
                                throw new TskCoreException("Given content (id: " + c.getId() + ") has no parent");
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Parent Info for Content", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        ObjectInfo getParentInfo(long contentId) throws TskCoreException {
                // TODO: This should not throw an exception if Content has no parent,
                // return null instead.
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT parent.obj_id AS obj_id, parent.type AS type " //NON-NLS
                                        + "FROM tsk_objects AS parent INNER JOIN tsk_objects AS child " //NON-NLS
                                        + "ON child.par_obj_id = parent.obj_id " //NON-NLS
                                        + "WHERE child.obj_id = " + contentId); //NON-NLS
                        if (rs.next()) {
                                return new ObjectInfo(rs.getLong("obj_id"), ObjectType.valueOf(rs.getShort("type")));
                        } else {
                                throw new TskCoreException("Given content (id: " + contentId + ") has no parent.");
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Parent Info for Content: " + contentId, ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        Directory getParentDirectory(FsContent fsc) throws TskCoreException {
                // TODO: This should not throw an exception if Content has no parent,
                // return null instead.
                if (fsc.isRoot()) {
                        throw new TskCoreException("Given FsContent (id: " + fsc.getId() + ") is a root object (can't have parent directory).");
                } else {
                        ObjectInfo parentInfo = getParentInfo(fsc);
                        Directory parent = null;
                        if (parentInfo.type == ObjectType.ABSTRACTFILE) {
                                parent = getDirectoryById(parentInfo.id, fsc.getFileSystem());
                        } else {
                                throw new TskCoreException("Parent of FsContent (id: " + fsc.getId() + ") has wrong type to be directory: " + parentInfo.type);
                        }
                        return parent;
                }
        }

        public Content getContentById(long id) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_objects WHERE obj_id = " + id + " LIMIT  1"); //NON-NLS
                        if (!rs.next()) {
                                return null;
                        }

                        AbstractContent content = null;
                        long parentId = rs.getLong("par_obj_id"); //NON-NLS
                        final TskData.ObjectType type = TskData.ObjectType.valueOf(rs.getShort("type")); //NON-NLS
                        switch (type) {
                                case IMG:
                                        content = getImageById(id);
                                        break;
                                case VS:
                                        content = getVolumeSystemById(id, parentId);
                                        break;
                                case VOL:
                                        content = getVolumeById(id, parentId);
                                        break;
                                case FS:
                                        content = getFileSystemById(id, parentId);
                                        break;
                                case ABSTRACTFILE:
                                        content = getAbstractFileById(id);
                                        break;
                                default:
                                        throw new TskCoreException("Could not obtain Content object with ID: " + id);
                        }
                        return content;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Content by ID.", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        String getFilePath(long id) {
                CaseDbConnection connection;
                try {
                        connection = connections.getConnection();
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error getting file path for file " + id, ex); //NON-NLS
                        return null;
                }
                String filePath = null;
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_LOCAL_PATH_FOR_FILE);
                        statement.clearParameters();
                        statement.setLong(1, id);
                        rs = connection.executeQuery(statement);
                        if (rs.next()) {
                                filePath = rs.getString("path");
                        }
                } catch (SQLException ex) {
                        logger.log(Level.SEVERE, "Error getting file path for file " + id, ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
                return filePath;
        }

        TskData.EncodingType getEncodingType(long id) {
                CaseDbConnection connection;
                try {
                        connection = connections.getConnection();
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error getting file path for file " + id, ex); //NON-NLS
                        return null;
                }
                TskData.EncodingType type = TskData.EncodingType.NONE;
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_ENCODING_FOR_FILE);
                        statement.clearParameters();
                        statement.setLong(1, id);
                        rs = connection.executeQuery(statement);
                        if (rs.next()) {
                                type = TskData.EncodingType.valueOf(rs.getInt(1));
                        }
                } catch (SQLException ex) {
                        logger.log(Level.SEVERE, "Error getting encoding type for file " + id, ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
                return type;
        }

        String getFileParentPath(long objectId, CaseDbConnection connection) {
                String parentPath = null;
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_PATH_FOR_FILE);
                        statement.clearParameters();
                        statement.setLong(1, objectId);
                        rs = connection.executeQuery(statement);
                        if (rs.next()) {
                                parentPath = rs.getString("parent_path");
                        }
                } catch (SQLException ex) {
                        logger.log(Level.SEVERE, "Error getting file parent_path for file " + objectId, ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        releaseSharedLock();
                }
                return parentPath;
        }

        String getFileName(long objectId, CaseDbConnection connection) {
                String fileName = null;
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILE_NAME);
                        statement.clearParameters();
                        statement.setLong(1, objectId);
                        rs = connection.executeQuery(statement);
                        if (rs.next()) {
                                fileName = rs.getString("name");
                        }
                } catch (SQLException ex) {
                        logger.log(Level.SEVERE, "Error getting file parent_path for file " + objectId, ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        releaseSharedLock();
                }
                return fileName;
        }

        DerivedFile.DerivedMethod getDerivedMethod(long id) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                DerivedFile.DerivedMethod method = null;
                acquireSharedLock();
                ResultSet rs1 = null;
                ResultSet rs2 = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_DERIVED_FILE);
                        statement.clearParameters();
                        statement.setLong(1, id);
                        rs1 = connection.executeQuery(statement);
                        if (rs1.next()) {
                                int method_id = rs1.getInt("derived_id");
                                String rederive = rs1.getString("rederive");
                                method = new DerivedFile.DerivedMethod(method_id, rederive);
                                statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILE_DERIVATION_METHOD);
                                statement.clearParameters();
                                statement.setInt(1, method_id);
                                rs2 = connection.executeQuery(statement);
                                if (rs2.next()) {
                                        method.setToolName(rs2.getString("tool_name"));
                                        method.setToolVersion(rs2.getString("tool_version"));
                                        method.setOther(rs2.getString("other"));
                                }
                        }
                } catch (SQLException e) {
                        logger.log(Level.SEVERE, "Error getting derived method for file: " + id, e); //NON-NLS
                } finally {
                        closeResultSet(rs2);
                        closeResultSet(rs1);
                        connection.close();
                        releaseSharedLock();
                }
                return method;
        }

        public AbstractFile getAbstractFileById(long id) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet rs = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILE_BY_ID);
                        statement.clearParameters();
                        statement.setLong(1, id);
                        rs = connection.executeQuery(statement);
                        List<AbstractFile> files = resultSetToAbstractFiles(rs, connection);
                        if (files.size() > 0) {
                                return files.get(0);
                        } else {
                                return null;
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting file by id, id = " + id, ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseSharedLock();
                }
        }

        private long getFileSystemId(long fileId, CaseDbConnection connection) {
                acquireSharedLock();
                ResultSet rs = null;
                long ret = -1;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILE_SYSTEM_BY_OBJECT);
                        statement.clearParameters();
                        statement.setLong(1, fileId);
                        rs = connection.executeQuery(statement);
                        if (rs.next()) {
                                ret = rs.getLong("fs_obj_id");
                                if (ret == 0) {
                                        ret = -1;
                                }
                        }
                } catch (SQLException e) {
                        logger.log(Level.SEVERE, "Error checking file system id of a file, id = " + fileId, e); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        releaseSharedLock();
                }
                return ret;
        }

        public boolean isFileFromSource(Content dataSource, long fileId) throws TskCoreException {
                String query = String.format("SELECT COUNT(*) AS count FROM tsk_files WHERE obj_id = %d AND data_source_obj_id = %d", fileId, dataSource.getId()); //NON-NLS
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        resultSet = connection.executeQuery(statement, query);
                        resultSet.next();
                        return (resultSet.getLong("count") > 0L);
                } catch (SQLException ex) {
                        throw new TskCoreException(String.format("Error executing query %s", query), ex);
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<AbstractFile> findFiles(Content dataSource, String fileName) throws TskCoreException {
                List<AbstractFile> files = new ArrayList<AbstractFile>();
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILES_BY_DATA_SOURCE_AND_NAME);
                        statement.clearParameters();
                        statement.setString(1, fileName.toLowerCase());
                        statement.setLong(2, dataSource.getId());
                        resultSet = connection.executeQuery(statement);
                        files.addAll(resultSetToAbstractFiles(resultSet, connection));
                } catch (SQLException e) {
                        throw new TskCoreException(bundle.getString("SleuthkitCase.findFiles.exception.msg3.text"), e);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
                return files;
        }

        public List<AbstractFile> findFiles(Content dataSource, String fileName, String dirName) throws TskCoreException {
                List<AbstractFile> files = new ArrayList<AbstractFile>();
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_FILES_BY_DATA_SOURCE_AND_PARENT_PATH_AND_NAME);
                        statement.clearParameters();
                        statement.setString(1, fileName.toLowerCase());
                        statement.setString(2, "%" + dirName.toLowerCase() + "%"); //NON-NLS
                        statement.setLong(3, dataSource.getId());
                        resultSet = connection.executeQuery(statement);
                        files.addAll(resultSetToAbstractFiles(resultSet, connection));
                } catch (SQLException e) {
                        throw new TskCoreException(bundle.getString("SleuthkitCase.findFiles3.exception.msg3.text"), e);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
                return files;
        }

        public VirtualDirectory addVirtualDirectory(long parentId, String directoryName) throws TskCoreException {
                acquireExclusiveLock();
                CaseDbTransaction localTrans = beginTransaction();
                try {
                        VirtualDirectory newVD = addVirtualDirectory(parentId, directoryName, localTrans);
                        localTrans.commit();
                        return newVD;
                } catch (TskCoreException ex) {
                        try {
                                localTrans.rollback();
                        } catch (TskCoreException ex2) {
                                logger.log(Level.SEVERE, String.format("Failed to rollback transaction after exception: %s", ex.getMessage()), ex2);
                        }
                        throw ex;
                } finally {
                        releaseExclusiveLock();
                }
        }

        public VirtualDirectory addVirtualDirectory(long parentId, String directoryName, CaseDbTransaction transaction) throws TskCoreException {
                if (transaction == null) {
                        throw new TskCoreException("Passed null CaseDbTransaction");
                }

                acquireExclusiveLock();
                ResultSet resultSet = null;
                try {
                        // Get the parent path.
                        CaseDbConnection connection = transaction.getConnection();
                        String parentPath = getFileParentPath(parentId, connection);
                        if (parentPath == null) {
                                parentPath = "/"; //NON-NLS
                        }
                        String parentName = getFileName(parentId, connection);
                        if (parentName != null && !parentName.isEmpty()) {
                                parentPath = parentPath + parentName + "/"; //NON-NLS
                        }

                        // Insert a row for the virtual directory into the tsk_objects table.
                        // INSERT INTO tsk_objects (par_obj_id, type) VALUES (?, ?)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_OBJECT, Statement.RETURN_GENERATED_KEYS);
                        statement.clearParameters();
                        if (parentId != 0) {
                                statement.setLong(1, parentId);
                        } else {
                                statement.setNull(1, java.sql.Types.BIGINT);
                        }
                        statement.setInt(2, TskData.ObjectType.ABSTRACTFILE.getObjectType());
                        connection.executeUpdate(statement);
                        resultSet = statement.getGeneratedKeys();
                        resultSet.next();
                        long newObjId = resultSet.getLong(1); //last_insert_rowid()

                        // Insert a row for the virtual directory into the tsk_files table.
                        // INSERT INTO tsk_files (obj_id, fs_obj_id, name, type, has_path, dir_type, meta_type,
                        // dir_flags, meta_flags, size, ctime, crtime, atime, mtime, parent_path, data_source_obj_id)
                        // VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
                        statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_FILE);
                        statement.clearParameters();
                        statement.setLong(1, newObjId);

                        // If the parent is part of a file system, grab its file system ID
                        if (0 != parentId) {
                                long parentFs = this.getFileSystemId(parentId, connection);
                                if (parentFs != -1) {
                                        statement.setLong(2, parentFs);
                                } else {
                                        statement.setNull(2, java.sql.Types.BIGINT);
                                }
                        } else {
                                statement.setNull(2, java.sql.Types.BIGINT);
                        }

                        // name
                        statement.setString(3, directoryName);

                        //type
                        statement.setShort(4, TskData.TSK_DB_FILES_TYPE_ENUM.VIRTUAL_DIR.getFileType());
                        statement.setShort(5, (short) 1);

                        //flags
                        final TSK_FS_NAME_TYPE_ENUM dirType = TSK_FS_NAME_TYPE_ENUM.DIR;
                        statement.setShort(6, dirType.getValue());
                        final TSK_FS_META_TYPE_ENUM metaType = TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_DIR;
                        statement.setShort(7, metaType.getValue());

                        //allocated
                        final TSK_FS_NAME_FLAG_ENUM dirFlag = TSK_FS_NAME_FLAG_ENUM.ALLOC;
                        statement.setShort(8, dirFlag.getValue());
                        final short metaFlags = (short) (TSK_FS_META_FLAG_ENUM.ALLOC.getValue()
                                        | TSK_FS_META_FLAG_ENUM.USED.getValue());
                        statement.setShort(9, metaFlags);

                        //size
                        statement.setLong(10, 0);

                        //  nulls for params 11-14
                        statement.setNull(11, java.sql.Types.BIGINT);
                        statement.setNull(12, java.sql.Types.BIGINT);
                        statement.setNull(13, java.sql.Types.BIGINT);
                        statement.setNull(14, java.sql.Types.BIGINT);

                        // parent path
                        statement.setString(15, parentPath);

                        // data source object id (same as object id if this is a data source)
                        long dataSourceObjectId;
                        if (0 == parentId) {
                                dataSourceObjectId = newObjId;
                        } else {
                                dataSourceObjectId = getDataSourceObjectId(connection, parentId);
                        }
                        statement.setLong(16, dataSourceObjectId);

                        connection.executeUpdate(statement);

                        return new VirtualDirectory(this, newObjId, dataSourceObjectId, directoryName, dirType,
                                        metaType, dirFlag, metaFlags, null, FileKnown.UNKNOWN,
                                        parentPath);
                } catch (SQLException e) {
                        throw new TskCoreException("Error creating virtual directory '" + directoryName + "'", e);
                } finally {
                        closeResultSet(resultSet);
                        releaseExclusiveLock();
                }
        }

        public LocalFilesDataSource addLocalFilesDataSource(String deviceId, String rootDirectoryName, String timeZone, CaseDbTransaction transaction) throws TskCoreException {
                acquireExclusiveLock();
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        // Insert a row for the root virtual directory of the data source
                        // into the tsk_objects table.
                        // INSERT INTO tsk_objects (par_obj_id, type) VALUES (?, ?)
                        CaseDbConnection connection = transaction.getConnection();
                        PreparedStatement preparedStatement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_OBJECT, Statement.RETURN_GENERATED_KEYS);
                        preparedStatement.clearParameters();
                        preparedStatement.setNull(1, java.sql.Types.BIGINT);
                        preparedStatement.setInt(2, TskData.ObjectType.ABSTRACTFILE.getObjectType());
                        connection.executeUpdate(preparedStatement);
                        resultSet = preparedStatement.getGeneratedKeys();
                        resultSet.next();
                        long newObjId = resultSet.getLong(1); //last_insert_rowid()
                        resultSet.close();
                        resultSet = null;

                        // Insert a row for the virtual directory of the data source into
                        // the data_source_info table.
                        statement = connection.createStatement();
                        statement.executeUpdate("INSERT INTO data_source_info (obj_id, device_id, time_zone) "
                                        + "VALUES(" + newObjId + ", '" + deviceId + "', '" + timeZone + "');");

                        // Insert a row for the root virtual directory of the data source
                        // into the tsk_files table. Note that its data source object id is
                        // its own object id.
                        // INSERT INTO tsk_files (obj_id, fs_obj_id, name, type, has_path,
                        // dir_type, meta_type, dir_flags, meta_flags, size, ctime, crtime,
                        // atime, mtime, parent_path, data_source_obj_id)
                        // VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
                        preparedStatement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_FILE);
                        preparedStatement.clearParameters();
                        preparedStatement.setLong(1, newObjId);
                        preparedStatement.setNull(2, java.sql.Types.BIGINT);
                        preparedStatement.setString(3, rootDirectoryName);
                        preparedStatement.setShort(4, TskData.TSK_DB_FILES_TYPE_ENUM.VIRTUAL_DIR.getFileType());
                        preparedStatement.setShort(5, (short) 1);
                        TSK_FS_NAME_TYPE_ENUM dirType = TSK_FS_NAME_TYPE_ENUM.DIR;
                        preparedStatement.setShort(6, TSK_FS_NAME_TYPE_ENUM.DIR.getValue());
                        TSK_FS_META_TYPE_ENUM metaType = TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_DIR;
                        preparedStatement.setShort(7, metaType.getValue());
                        TSK_FS_NAME_FLAG_ENUM dirFlag = TSK_FS_NAME_FLAG_ENUM.ALLOC;
                        preparedStatement.setShort(8, dirFlag.getValue());
                        final short metaFlags = (short) (TSK_FS_META_FLAG_ENUM.ALLOC.getValue()
                                        | TSK_FS_META_FLAG_ENUM.USED.getValue());
                        preparedStatement.setShort(9, metaFlags);
                        preparedStatement.setLong(10, 0);
                        preparedStatement.setNull(11, java.sql.Types.BIGINT);
                        preparedStatement.setNull(12, java.sql.Types.BIGINT);
                        preparedStatement.setNull(13, java.sql.Types.BIGINT);
                        preparedStatement.setNull(14, java.sql.Types.BIGINT);
                        String parentPath = "/"; //NON-NLS
                        preparedStatement.setString(15, parentPath);
                        preparedStatement.setLong(16, newObjId);
                        connection.executeUpdate(preparedStatement);

                        VirtualDirectory rootDirectory = new VirtualDirectory(this,
                                        newObjId, newObjId, rootDirectoryName,
                                        dirType, metaType, dirFlag, metaFlags, null,
                                        FileKnown.UNKNOWN, parentPath);
                        return new LocalFilesDataSource(deviceId, rootDirectory, timeZone);

                } catch (SQLException ex) {
                        throw new TskCoreException(String.format("Error creating local files data source with device id %s and directory name %s", deviceId, rootDirectoryName), ex);
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        releaseExclusiveLock();
                }
        }

        public List<VirtualDirectory> getVirtualDirectoryRoots() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_files WHERE" //NON-NLS
                                        + " type = " + TskData.TSK_DB_FILES_TYPE_ENUM.VIRTUAL_DIR.getFileType()
                                        + " AND obj_id = data_source_obj_id"
                                        + " ORDER BY dir_type, LOWER(name)"); //NON-NLS
                        List<VirtualDirectory> virtDirRootIds = new ArrayList<VirtualDirectory>();
                        while (rs.next()) {
                                virtDirRootIds.add(virtualDirectory(rs));
                        }
                        return virtDirRootIds;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting local files virtual folder id", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public final List<LayoutFile> addLayoutFiles(Content parent, List<TskFileRange> fileRanges) throws TskCoreException {
                assert (null != fileRanges);
                if (null == fileRanges) {
                        throw new TskCoreException("TskFileRange object is null");
                }

                assert (null != parent);
                if (null == parent) {
                        throw new TskCoreException("Conent is null");
                }

                CaseDbTransaction transaction = null;
                Statement statement = null;
                ResultSet resultSet = null;
                acquireExclusiveLock();

                try {
                        transaction = beginTransaction();
                        CaseDbConnection connection = transaction.getConnection();

                        List<LayoutFile> fileRangeLayoutFiles = new ArrayList<LayoutFile>();
                        for (TskFileRange fileRange : fileRanges) {
                                /*
                                 * Insert a row for the Tsk file range into the tsk_objects
                                 * table: INSERT INTO tsk_objects (par_obj_id, type) VALUES (?,
                                 * ?)
                                 */
                                PreparedStatement prepStmt = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_OBJECT, Statement.RETURN_GENERATED_KEYS);
                                prepStmt.clearParameters();
                                prepStmt.setLong(1, parent.getId()); // par_obj_id
                                prepStmt.setLong(2, TskData.ObjectType.ABSTRACTFILE.getObjectType()); // type
                                connection.executeUpdate(prepStmt);
                                resultSet = prepStmt.getGeneratedKeys();
                                resultSet.next();
                                long fileRangeId = resultSet.getLong(1); //last_insert_rowid()
                                long end_byte_in_parent = fileRange.getByteStart() + fileRange.getByteLen() - 1;
                                /*
                                 * Insert a row for the Tsk file range into the tsk_files table:
                                 * INSERT INTO tsk_files (obj_id, fs_obj_id, name, type,
                                 * has_path, dir_type, meta_type, dir_flags, meta_flags, size,
                                 * ctime, crtime, atime, mtime, parent_path, data_source_obj_id)
                                 * VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
                                 */
                                prepStmt = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_FILE);
                                prepStmt.clearParameters();
                                prepStmt.setLong(1, fileRangeId); // obj_id     from tsk_objects                        
                                prepStmt.setNull(2, java.sql.Types.BIGINT); // fs_obj_id                                
                                prepStmt.setString(3, "Unalloc_" + parent.getId() + "_" + fileRange.getByteStart() + "_" + end_byte_in_parent); // name of form Unalloc_[image obj_id]_[start byte in parent]_[end byte in parent]
                                prepStmt.setShort(4, TSK_DB_FILES_TYPE_ENUM.UNALLOC_BLOCKS.getFileType()); // type
                                prepStmt.setNull(5, java.sql.Types.BIGINT); // has_path
                                prepStmt.setShort(6, TSK_FS_NAME_TYPE_ENUM.REG.getValue()); // dir_type
                                prepStmt.setShort(7, TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_REG.getValue()); // meta_type
                                prepStmt.setShort(8, TSK_FS_NAME_FLAG_ENUM.UNALLOC.getValue()); // dir_flags
                                prepStmt.setShort(9, TSK_FS_META_FLAG_ENUM.UNALLOC.getValue()); // nmeta_flags
                                prepStmt.setLong(10, fileRange.getByteLen()); // size 
                                prepStmt.setNull(11, java.sql.Types.BIGINT); // ctime
                                prepStmt.setNull(12, java.sql.Types.BIGINT); // crtime
                                prepStmt.setNull(13, java.sql.Types.BIGINT); // atime
                                prepStmt.setNull(14, java.sql.Types.BIGINT); // mtime
                                prepStmt.setNull(15, java.sql.Types.VARCHAR); // parent path
                                prepStmt.setLong(16, parent.getId()); // data_source_obj_id
                                connection.executeUpdate(prepStmt);

                                /*
                                 * Insert a row in the tsk_layout_file table for each chunk of
                                 * the carved file. INSERT INTO tsk_file_layout (obj_id,
                                 * byte_start, byte_len, sequence) VALUES (?, ?, ?, ?)
                                 */
                                prepStmt = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_LAYOUT_FILE);
                                prepStmt.clearParameters();
                                prepStmt.setLong(1, fileRangeId); // obj_id
                                prepStmt.setLong(2, fileRange.getByteStart()); // byte_start
                                prepStmt.setLong(3, fileRange.getByteLen()); // byte_len
                                prepStmt.setLong(4, fileRange.getSequence()); // sequence
                                connection.executeUpdate(prepStmt);

                                /*
                                 * Create a layout file representation of the carved file.
                                 */
                                fileRangeLayoutFiles.add(new LayoutFile(this,
                                                fileRangeId,
                                                parent.getId(),
                                                Long.toString(fileRange.getSequence()),
                                                TSK_DB_FILES_TYPE_ENUM.UNALLOC_BLOCKS,
                                                TSK_FS_NAME_TYPE_ENUM.REG,
                                                TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_REG,
                                                TSK_FS_NAME_FLAG_ENUM.UNALLOC,
                                                TSK_FS_META_FLAG_ENUM.UNALLOC.getValue(),
                                                fileRange.getByteLen(),
                                                null,
                                                FileKnown.UNKNOWN,
                                                parent.getUniquePath(),
                                                null));
                        }

                        transaction.commit();
                        return fileRangeLayoutFiles;

                } catch (SQLException ex) {
                        if (null != transaction) {
                                try {
                                        transaction.rollback();
                                } catch (TskCoreException ex2) {
                                        logger.log(Level.SEVERE, String.format("Failed to rollback transaction after exception: %s", ex.getMessage()), ex2);
                                }
                        }
                        throw new TskCoreException("Failed to add layout files to case database", ex);

                } catch (TskCoreException ex) {
                        if (null != transaction) {
                                try {
                                        transaction.rollback();
                                } catch (TskCoreException ex2) {
                                        logger.log(Level.SEVERE, String.format("Failed to rollback transaction after exception: %s", ex.getMessage()), ex2);
                                }
                        }
                        throw ex;

                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        releaseExclusiveLock();
                }
        }

        public final List<LayoutFile> addCarvedFiles(CarvingResult carvingResult) throws TskCoreException {
                assert (null != carvingResult);
                if (null == carvingResult) {
                        throw new TskCoreException("Carving is null");
                }
                assert (null != carvingResult.getParent());
                if (null == carvingResult.getParent()) {
                        throw new TskCoreException("Carving result has null parent");
                }
                assert (null != carvingResult.getCarvedFiles());
                if (null == carvingResult.getCarvedFiles()) {
                        throw new TskCoreException("Carving result has null carved files");
                }
                CaseDbTransaction transaction = null;
                Statement statement = null;
                ResultSet resultSet = null;
                acquireExclusiveLock();
                long newCacheKey = 0; // Used to roll back cache if transaction is rolled back.
                try {
                        transaction = beginTransaction();
                        CaseDbConnection connection = transaction.getConnection();

                        /*
                         * Carved files are "re-parented" as children of the $CarvedFiles
                         * virtual directory of the root file system, volume, or image
                         * ancestor of the carved files parent, but if no such ancestor is
                         * found, then the parent specified in the carving result is used.
                         */
                        Content root = carvingResult.getParent();
                        while (null != root) {
                                if (root instanceof FileSystem || root instanceof Volume || root instanceof Image) {
                                        break;
                                }
                                root = root.getParent();
                        }
                        if (null == root) {
                                root = carvingResult.getParent();
                        }

                        /*
                         * Get or create the $CarvedFiles virtual directory for the root
                         * ancestor.
                         */
                        VirtualDirectory carvedFilesDir = rootIdsToCarvedFileDirs.get(root.getId());
                        if (null == carvedFilesDir) {
                                List<Content> rootChildren;
                                if (root instanceof FileSystem) {
                                        rootChildren = ((FileSystem) root).getRootDirectory().getChildren();
                                } else {
                                        rootChildren = root.getChildren();
                                }
                                for (Content child : rootChildren) {
                                        if (child instanceof VirtualDirectory && child.getName().equals(VirtualDirectory.NAME_CARVED)) {
                                                carvedFilesDir = (VirtualDirectory) child;
                                                break;
                                        }
                                }
                                if (null == carvedFilesDir) {
                                        long parId = root.getId();
                                        // $CarvedFiles should be a child of the root directory, not the file system
                                        if (root instanceof FileSystem) {
                                                Content rootDir = ((FileSystem) root).getRootDirectory();
                                                parId = rootDir.getId();
                                        }
                                        carvedFilesDir = addVirtualDirectory(parId, VirtualDirectory.NAME_CARVED, transaction);
                                }
                                newCacheKey = root.getId();
                                rootIdsToCarvedFileDirs.put(newCacheKey, carvedFilesDir);
                        }

                        /*
                         * Add the carved files to the database as children of the
                         * $CarvedFile directory of the root ancestor.
                         */
                        String parentPath = getFileParentPath(carvedFilesDir.getId(), connection) + carvedFilesDir.getName() + "/";
                        List<LayoutFile> carvedFiles = new ArrayList<LayoutFile>();
                        for (CarvingResult.CarvedFile carvedFile : carvingResult.getCarvedFiles()) {
                                /*
                                 * Insert a row for the carved file into the tsk_objects table:
                                 * INSERT INTO tsk_objects (par_obj_id, type) VALUES (?, ?)
                                 */
                                PreparedStatement prepStmt = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_OBJECT, Statement.RETURN_GENERATED_KEYS);
                                prepStmt.clearParameters();
                                prepStmt.setLong(1, carvedFilesDir.getId()); // par_obj_id
                                prepStmt.setLong(2, TskData.ObjectType.ABSTRACTFILE.getObjectType()); // type
                                connection.executeUpdate(prepStmt);
                                resultSet = prepStmt.getGeneratedKeys();
                                resultSet.next();
                                long carvedFileId = resultSet.getLong(1); //last_insert_rowid()

                                /*
                                 * Insert a row for the carved file into the tsk_files table:
                                 * INSERT INTO tsk_files (obj_id, fs_obj_id, name, type,
                                 * has_path, dir_type, meta_type, dir_flags, meta_flags, size,
                                 * ctime, crtime, atime, mtime, parent_path, data_source_obj_id)
                                 * VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
                                 */
                                prepStmt = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_FILE);
                                prepStmt.clearParameters();
                                prepStmt.setLong(1, carvedFileId); // obj_id
                                if (root instanceof FileSystem) {
                                        prepStmt.setLong(2, root.getId()); // fs_obj_id
                                } else {
                                        prepStmt.setNull(2, java.sql.Types.BIGINT); // fs_obj_id
                                }
                                prepStmt.setString(3, carvedFile.getName()); // name
                                prepStmt.setShort(4, TSK_DB_FILES_TYPE_ENUM.CARVED.getFileType()); // type
                                prepStmt.setShort(5, (short) 1); // has_path
                                prepStmt.setShort(6, TSK_FS_NAME_TYPE_ENUM.REG.getValue()); // dir_type
                                prepStmt.setShort(7, TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_REG.getValue()); // meta_type
                                prepStmt.setShort(8, TSK_FS_NAME_FLAG_ENUM.UNALLOC.getValue()); // dir_flags
                                prepStmt.setShort(9, TSK_FS_META_FLAG_ENUM.UNALLOC.getValue()); // nmeta_flags
                                prepStmt.setLong(10, carvedFile.getSizeInBytes()); // size
                                prepStmt.setNull(11, java.sql.Types.BIGINT); // ctime
                                prepStmt.setNull(12, java.sql.Types.BIGINT); // crtime
                                prepStmt.setNull(13, java.sql.Types.BIGINT); // atime
                                prepStmt.setNull(14, java.sql.Types.BIGINT); // mtime
                                prepStmt.setString(15, parentPath); // parent path
                                prepStmt.setLong(16, carvedFilesDir.getDataSourceObjectId()); // data_source_obj_id
                                connection.executeUpdate(prepStmt);

                                /*
                                 * Insert a row in the tsk_layout_file table for each chunk of
                                 * the carved file. INSERT INTO tsk_file_layout (obj_id,
                                 * byte_start, byte_len, sequence) VALUES (?, ?, ?, ?)
                                 */
                                prepStmt = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_LAYOUT_FILE);
                                for (TskFileRange tskFileRange : carvedFile.getLayoutInParent()) {
                                        prepStmt.clearParameters();
                                        prepStmt.setLong(1, carvedFileId); // obj_id
                                        prepStmt.setLong(2, tskFileRange.getByteStart()); // byte_start
                                        prepStmt.setLong(3, tskFileRange.getByteLen()); // byte_len
                                        prepStmt.setLong(4, tskFileRange.getSequence()); // sequence
                                        connection.executeUpdate(prepStmt);
                                }

                                /*
                                 * Create a layout file representation of the carved file.
                                 */
                                carvedFiles.add(new LayoutFile(this,
                                                carvedFileId,
                                                carvedFilesDir.getDataSourceObjectId(),
                                                carvedFile.getName(),
                                                TSK_DB_FILES_TYPE_ENUM.CARVED,
                                                TSK_FS_NAME_TYPE_ENUM.REG,
                                                TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_REG,
                                                TSK_FS_NAME_FLAG_ENUM.UNALLOC,
                                                TSK_FS_META_FLAG_ENUM.UNALLOC.getValue(),
                                                carvedFile.getSizeInBytes(),
                                                null,
                                                FileKnown.UNKNOWN,
                                                parentPath,
                                                null));
                        }

                        transaction.commit();
                        return carvedFiles;

                } catch (SQLException ex) {
                        if (null != transaction) {
                                try {
                                        transaction.rollback();
                                } catch (TskCoreException ex2) {
                                        logger.log(Level.SEVERE, String.format("Failed to rollback transaction after exception: %s", ex.getMessage()), ex2);
                                }
                                if (0 != newCacheKey) {
                                        rootIdsToCarvedFileDirs.remove(newCacheKey);
                                }
                        }
                        throw new TskCoreException("Failed to add carved files to case database", ex);

                } catch (TskCoreException ex) {
                        if (null != transaction) {
                                try {
                                        transaction.rollback();
                                } catch (TskCoreException ex2) {
                                        logger.log(Level.SEVERE, String.format("Failed to rollback transaction after exception: %s", ex.getMessage()), ex2);
                                }
                                if (0 != newCacheKey) {
                                        rootIdsToCarvedFileDirs.remove(newCacheKey);
                                }
                        }
                        throw ex;

                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        releaseExclusiveLock();
                }
        }

        public DerivedFile addDerivedFile(String fileName, String localPath,
                        long size, long ctime, long crtime, long atime, long mtime,
                        boolean isFile, AbstractFile parentFile,
                        String rederiveDetails, String toolName, String toolVersion,
                        String otherDetails, TskData.EncodingType encodingType) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                ResultSet rs = null;
                try {
                        connection.beginTransaction();

                        final long parentId = parentFile.getId();
                        final String parentPath = parentFile.getParentPath() + parentFile.getName() + '/'; //NON-NLS

                        // Insert a row for the derived file into the tsk_objects table.
                        // INSERT INTO tsk_objects (par_obj_id, type) VALUES (?, ?)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_OBJECT, Statement.RETURN_GENERATED_KEYS);
                        statement.clearParameters();
                        statement.setLong(1, parentId);
                        statement.setLong(2, TskData.ObjectType.ABSTRACTFILE.getObjectType());
                        connection.executeUpdate(statement);
                        rs = statement.getGeneratedKeys();
                        rs.next();
                        long newObjId = rs.getLong(1); //last_insert_rowid()
                        rs.close();
                        rs = null;

                        // Insert a row for the virtual directory into the tsk_files table.
                        // INSERT INTO tsk_files (obj_id, fs_obj_id, name, type, has_path, dir_type, meta_type,
                        // dir_flags, meta_flags, size, ctime, crtime, atime, mtime, parent_path, data_source_obj_id)
                        // VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
                        statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_FILE);
                        statement.clearParameters();
                        statement.setLong(1, newObjId);

                        // If the parentFile is part of a file system, use its file system object ID.
                        long fsObjId = this.getFileSystemId(parentId, connection);
                        if (fsObjId != -1) {
                                statement.setLong(2, fsObjId);
                        } else {
                                statement.setNull(2, java.sql.Types.BIGINT);
                        }
                        statement.setString(3, fileName);

                        //type, has_path
                        statement.setShort(4, TskData.TSK_DB_FILES_TYPE_ENUM.DERIVED.getFileType());
                        statement.setShort(5, (short) 1);

                        //flags
                        final TSK_FS_NAME_TYPE_ENUM dirType = isFile ? TSK_FS_NAME_TYPE_ENUM.REG : TSK_FS_NAME_TYPE_ENUM.DIR;
                        statement.setShort(6, dirType.getValue());
                        final TSK_FS_META_TYPE_ENUM metaType = isFile ? TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_REG : TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_DIR;
                        statement.setShort(7, metaType.getValue());

                        //note: using alloc under assumption that derived files derive from alloc files
                        final TSK_FS_NAME_FLAG_ENUM dirFlag = TSK_FS_NAME_FLAG_ENUM.ALLOC;
                        statement.setShort(8, dirFlag.getValue());
                        final short metaFlags = (short) (TSK_FS_META_FLAG_ENUM.ALLOC.getValue()
                                        | TSK_FS_META_FLAG_ENUM.USED.getValue());
                        statement.setShort(9, metaFlags);

                        //size
                        statement.setLong(10, size);

                        //mactimes
                        //long ctime, long crtime, long atime, long mtime,
                        statement.setLong(11, ctime);
                        statement.setLong(12, crtime);
                        statement.setLong(13, atime);
                        statement.setLong(14, mtime);

                        //parent path
                        statement.setString(15, parentPath);

                        // root data source object id
                        long dataSourceObjId = getDataSourceObjectId(connection, parentId);
                        statement.setLong(16, dataSourceObjId);

                        connection.executeUpdate(statement);

                        //add localPath
                        addFilePath(connection, newObjId, localPath, encodingType);

                        connection.commitTransaction();

                        //TODO add derived method to tsk_files_derived and tsk_files_derived_method
                        return new DerivedFile(this, newObjId, dataSourceObjId, fileName, dirType, metaType, dirFlag, metaFlags,
                                        size, ctime, crtime, atime, mtime, null, null, parentPath, localPath, parentId, null, encodingType);
                } catch (SQLException ex) {
                        connection.rollbackTransaction();
                        throw new TskCoreException("Failed to add derived file to case database", ex);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public LocalFile addLocalFile(String fileName, String localPath,
                        long size, long ctime, long crtime, long atime, long mtime,
                        boolean isFile, TskData.EncodingType encodingType,
                        AbstractFile parent) throws TskCoreException {
                acquireExclusiveLock();
                CaseDbTransaction localTrans = beginTransaction();
                try {
                        LocalFile created = addLocalFile(fileName, localPath, size, ctime, crtime, atime, mtime, isFile, encodingType, parent, localTrans);
                        localTrans.commit();
                        return created;
                } catch (TskCoreException ex) {
                        try {
                                localTrans.rollback();
                        } catch (TskCoreException ex2) {
                                logger.log(Level.SEVERE, String.format("Failed to rollback transaction after exception: %s", ex.getMessage()), ex2);
                        }
                        throw ex;
                } finally {
                        releaseExclusiveLock();
                }
        }

        public LocalFile addLocalFile(String fileName, String localPath,
                        long size, long ctime, long crtime, long atime, long mtime,
                        boolean isFile, TskData.EncodingType encodingType,
                        AbstractFile parent, CaseDbTransaction transaction) throws TskCoreException {

                CaseDbConnection connection = transaction.getConnection();
                acquireExclusiveLock();
                Statement queryStatement = null;
                ResultSet resultSet = null;
                try {

                        // Insert a row for the local/logical file into the tsk_objects table.
                        // INSERT INTO tsk_objects (par_obj_id, type) VALUES (?, ?)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_OBJECT, Statement.RETURN_GENERATED_KEYS);
                        statement.clearParameters();
                        statement.setLong(1, parent.getId());
                        statement.setLong(2, TskData.ObjectType.ABSTRACTFILE.getObjectType());
                        connection.executeUpdate(statement);
                        resultSet = statement.getGeneratedKeys();
                        if (!resultSet.next()) {
                                throw new TskCoreException(String.format("Failed to INSERT local file %s (%s) with parent id %d in tsk_objects table", fileName, localPath, parent.getId()));
                        }
                        long objectId = resultSet.getLong(1); //last_insert_rowid()
                        resultSet.close();
                        resultSet = null;

                        // Insert a row for the local/logical file into the tsk_files table.
                        // INSERT INTO tsk_files (obj_id, fs_obj_id, name, type, has_path, dir_type, meta_type,
                        // dir_flags, meta_flags, size, ctime, crtime, atime, mtime, parent_path, data_source_obj_id)
                        // VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
                        statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_FILE);
                        statement.clearParameters();
                        statement.setLong(1, objectId);
                        statement.setNull(2, java.sql.Types.BIGINT); // Not part of a file system
                        statement.setString(3, fileName);
                        statement.setShort(4, TskData.TSK_DB_FILES_TYPE_ENUM.LOCAL.getFileType());
                        statement.setShort(5, (short) 1);
                        TSK_FS_NAME_TYPE_ENUM dirType = isFile ? TSK_FS_NAME_TYPE_ENUM.REG : TSK_FS_NAME_TYPE_ENUM.DIR;
                        statement.setShort(6, dirType.getValue());
                        TSK_FS_META_TYPE_ENUM metaType = isFile ? TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_REG : TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_DIR;
                        statement.setShort(7, metaType.getValue());
                        TSK_FS_NAME_FLAG_ENUM dirFlag = TSK_FS_NAME_FLAG_ENUM.ALLOC;
                        statement.setShort(8, dirFlag.getValue());
                        short metaFlags = (short) (TSK_FS_META_FLAG_ENUM.ALLOC.getValue() | TSK_FS_META_FLAG_ENUM.USED.getValue());
                        statement.setShort(9, metaFlags);
                        statement.setLong(10, size);
                        statement.setLong(11, ctime);
                        statement.setLong(12, crtime);
                        statement.setLong(13, atime);
                        statement.setLong(14, mtime);
                        String parentPath = parent.getParentPath() + parent.getName() + "/"; //NON-NLS
                        statement.setString(15, parentPath);
                        long dataSourceObjId = getDataSourceObjectId(connection, parent.getId()); // RJCTODO: Let this be passed in or make a story
                        statement.setLong(16, dataSourceObjId);
                        connection.executeUpdate(statement);
                        addFilePath(connection, objectId, localPath, encodingType);
                        return new LocalFile(this,
                                        objectId,
                                        fileName,
                                        TSK_DB_FILES_TYPE_ENUM.LOCAL,
                                        dirType,
                                        metaType,
                                        dirFlag,
                                        metaFlags,
                                        size,
                                        ctime, crtime, atime, mtime,
                                        null, null, null,
                                        parent.getId(), parentPath,
                                        dataSourceObjId,
                                        localPath,
                                        encodingType);

                } catch (SQLException ex) {
                        throw new TskCoreException(String.format("Failed to INSERT local file %s (%s) with parent id %d in tsk_files table", fileName, localPath, parent.getId()), ex);
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(queryStatement);
                        releaseExclusiveLock();
                }
        }

        private long getDataSourceObjectId(CaseDbConnection connection, long objectId) throws TskCoreException {
                acquireSharedLock();
                Statement statement = null;
                ResultSet resultSet = null;
                try {
                        statement = connection.createStatement();
                        long dataSourceObjId;
                        long ancestorId = objectId;
                        do {
                                dataSourceObjId = ancestorId;
                                String query = String.format("SELECT par_obj_id FROM tsk_objects WHERE obj_id = %s;", ancestorId);
                                resultSet = statement.executeQuery(query);
                                if (resultSet.next()) {
                                        ancestorId = resultSet.getLong("par_obj_id");
                                } else {
                                        throw new TskCoreException(String.format("tsk_objects table is corrupt, SQL query returned no result: %s", query));
                                }
                                resultSet.close();
                                resultSet = null;
                        } while (0 != ancestorId); // Not NULL
                        return dataSourceObjId;
                } catch (SQLException ex) {
                        throw new TskCoreException(String.format("Error finding root data source for object (obj_id = %d)", objectId), ex);
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        releaseSharedLock();
                }
        }

        private void addFilePath(CaseDbConnection connection, long objId, String path, TskData.EncodingType type) throws SQLException {
                PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_LOCAL_PATH);
                statement.clearParameters();
                statement.setLong(1, objId);
                statement.setString(2, path);
                statement.setInt(3, type.getType());
                connection.executeUpdate(statement);
        }

        public List<AbstractFile> findFiles(Content dataSource, String fileName, AbstractFile parentFile) throws TskCoreException {
                return findFiles(dataSource, fileName, parentFile.getName());
        }

        public long countFilesWhere(String sqlWhereClause) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT COUNT(*) AS count FROM tsk_files WHERE " + sqlWhereClause); //NON-NLS
                        rs.next();
                        return rs.getLong("count");
                } catch (SQLException e) {
                        throw new TskCoreException("SQLException thrown when calling 'SleuthkitCase.countFilesWhere().", e);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<AbstractFile> findAllFilesWhere(String sqlWhereClause) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_files WHERE " + sqlWhereClause); //NON-NLS
                        return resultSetToAbstractFiles(rs, connection);
                } catch (SQLException e) {
                        throw new TskCoreException("SQLException thrown when calling 'SleuthkitCase.findAllFilesWhere(): " + sqlWhereClause, e);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<Long> findAllFileIdsWhere(String sqlWhereClause) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT obj_id FROM tsk_files WHERE " + sqlWhereClause); //NON-NLS
                        List<Long> ret = new ArrayList<Long>();
                        while (rs.next()) {
                                ret.add(rs.getLong("obj_id"));
                        }
                        return ret;
                } catch (SQLException e) {
                        throw new TskCoreException("SQLException thrown when calling 'SleuthkitCase.findAllFileIdsWhere(): " + sqlWhereClause, e);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<AbstractFile> openFiles(Content dataSource, String filePath) throws TskCoreException {

                // get the non-unique path (strip of image and volume path segments, if
                // the exist.
                String path = AbstractFile.createNonUniquePath(filePath).toLowerCase();

                // split the file name from the parent path
                int lastSlash = path.lastIndexOf('/'); //NON-NLS

                // if the last slash is at the end, strip it off
                if (lastSlash == path.length()) {
                        path = path.substring(0, lastSlash - 1);
                        lastSlash = path.lastIndexOf('/'); //NON-NLS
                }

                String parentPath = path.substring(0, lastSlash);
                String fileName = path.substring(lastSlash);

                return findFiles(dataSource, fileName, parentPath);
        }

        public List<TskFileRange> getFileRanges(long id) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_file_layout WHERE obj_id = " + id + " ORDER BY sequence");
                        List<TskFileRange> ranges = new ArrayList<TskFileRange>();
                        while (rs.next()) {
                                TskFileRange range = new TskFileRange(rs.getLong("byte_start"), //NON-NLS
                                                rs.getLong("byte_len"), rs.getLong("sequence")); //NON-NLS
                                ranges.add(range);
                        }
                        return ranges;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting TskFileLayoutRanges by id, id = " + id, ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public Image getImageById(long id) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s1 = null;
                ResultSet rs1 = null;
                Statement s2 = null;
                ResultSet rs2 = null;
                try {
                        s1 = connection.createStatement();
                        rs1 = connection.executeQuery(s1, "SELECT * FROM tsk_image_info WHERE obj_id = " + id); //NON-NLS
                        if (rs1.next()) {
                                s2 = connection.createStatement();
                                rs2 = connection.executeQuery(s2, "SELECT * FROM tsk_image_names WHERE obj_id = " + rs1.getLong("obj_id")); //NON-NLS
                                List<String> imagePaths = new ArrayList<String>();
                                while (rs2.next()) {
                                        imagePaths.add(rs2.getString("name"));
                                }
                                long obj_id = rs1.getLong("obj_id"); //NON-NLS
                                long type = rs1.getLong("type"); //NON-NLS
                                long ssize = rs1.getLong("ssize"); //NON-NLS
                                String tzone = rs1.getString("tzone"); //NON-NLS
                                String md5 = "";
                                if (getSchemaVersion() > 2) {
                                        md5 = rs1.getString("md5"); //NON-NLS
                                }
                                String name = rs1.getString("display_name");
                                if (name == null) {
                                        if (imagePaths.size() > 0) {
                                                String path = imagePaths.get(0);
                                                name = (new java.io.File(path)).getName();
                                        } else {
                                                name = "";
                                        }
                                }
                                return new Image(this, obj_id, type, ssize, name,
                                                imagePaths.toArray(new String[imagePaths.size()]), tzone, md5);
                        } else {
                                throw new TskCoreException("No image found for id: " + id);
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Image by id, id = " + id, ex);
                } finally {
                        closeResultSet(rs2);
                        closeStatement(s2);
                        closeResultSet(rs1);
                        closeStatement(s1);
                        connection.close();
                        releaseSharedLock();
                }
        }

        VolumeSystem getVolumeSystemById(long id, Image parent) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_vs_info " //NON-NLS
                                        + "where obj_id = " + id); //NON-NLS
                        if (rs.next()) {
                                long type = rs.getLong("vs_type"); //NON-NLS
                                long imgOffset = rs.getLong("img_offset"); //NON-NLS
                                long blockSize = rs.getLong("block_size"); //NON-NLS
                                VolumeSystem vs = new VolumeSystem(this, id, "", type, imgOffset, blockSize);
                                vs.setParent(parent);
                                return vs;
                        } else {
                                throw new TskCoreException("No volume system found for id:" + id);
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Volume System by ID.", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        VolumeSystem getVolumeSystemById(long id, long parentId) throws TskCoreException {
                VolumeSystem vs = getVolumeSystemById(id, null);
                vs.setParentId(parentId);
                return vs;
        }

        FileSystem getFileSystemById(long id, Image parent) throws TskCoreException {
                return getFileSystemByIdHelper(id, parent);
        }

        FileSystem getFileSystemById(long id, long parentId) throws TskCoreException {
                Volume vol = null;
                FileSystem fs = getFileSystemById(id, vol);
                fs.setParentId(parentId);
                return fs;
        }

        FileSystem getFileSystemById(long id, Volume parent) throws TskCoreException {
                return getFileSystemByIdHelper(id, parent);
        }

        private FileSystem getFileSystemByIdHelper(long id, Content parent) throws TskCoreException {
                // see if we already have it
                // @@@ NOTE: this is currently kind of bad in that we are ignoring the parent value,
                // but it should be the same...
                synchronized (fileSystemIdMap) {
                        if (fileSystemIdMap.containsKey(id)) {
                                return fileSystemIdMap.get(id);
                        }
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_fs_info " //NON-NLS
                                        + "where obj_id = " + id); //NON-NLS
                        if (rs.next()) {
                                TskData.TSK_FS_TYPE_ENUM fsType = TskData.TSK_FS_TYPE_ENUM.valueOf(rs.getInt("fs_type")); //NON-NLS
                                FileSystem fs = new FileSystem(this, rs.getLong("obj_id"), "", rs.getLong("img_offset"), //NON-NLS
                                                fsType, rs.getLong("block_size"), rs.getLong("block_count"), //NON-NLS
                                                rs.getLong("root_inum"), rs.getLong("first_inum"), rs.getLong("last_inum")); //NON-NLS
                                fs.setParent(parent);
                                // save it for the next call
                                synchronized (fileSystemIdMap) {
                                        fileSystemIdMap.put(id, fs);
                                }
                                return fs;
                        } else {
                                throw new TskCoreException("No file system found for id:" + id);
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting File System by ID", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        Volume getVolumeById(long id, VolumeSystem parent) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_vs_parts " //NON-NLS
                                        + "where obj_id = " + id); //NON-NLS
                        if (rs.next()) {
                                String description;
                                try {
                                        description = rs.getString("desc");
                                } catch (Exception ex) {
                                        description = rs.getString("descr");
                                }
                                Volume vol = new Volume(this, rs.getLong("obj_id"), rs.getLong("addr"), //NON-NLS
                                                rs.getLong("start"), rs.getLong("length"), rs.getLong("flags"), //NON-NLS
                                                description);
                                vol.setParent(parent);
                                return vol;
                        } else {
                                throw new TskCoreException("No volume found for id:" + id);
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Volume by ID", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        Volume getVolumeById(long id, long parentId) throws TskCoreException {
                Volume vol = getVolumeById(id, null);
                vol.setParentId(parentId);
                return vol;
        }

        Directory getDirectoryById(long id, FileSystem parentFs) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_files " //NON-NLS
                                        + "WHERE obj_id = " + id);
                        Directory temp = null; //NON-NLS
                        if (rs.next()) {
                                final short type = rs.getShort("type"); //NON-NLS
                                if (type == TSK_DB_FILES_TYPE_ENUM.FS.getFileType()) {
                                        if (rs.getShort("meta_type") == TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_DIR.getValue()) { //NON-NLS
                                                temp = directory(rs, parentFs);
                                        }
                                } else if (type == TSK_DB_FILES_TYPE_ENUM.VIRTUAL_DIR.getFileType()) {
                                        throw new TskCoreException("Expecting an FS-type directory, got virtual, id: " + id);
                                }
                        } else {
                                throw new TskCoreException("No Directory found for id:" + id);
                        }
                        return temp;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting Directory by ID", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public Collection<FileSystem> getFileSystems(Image image) {
                List<FileSystem> fileSystems = new ArrayList<FileSystem>();
                CaseDbConnection connection;
                try {
                        connection = connections.getConnection();
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error getting file systems for image " + image.getId(), ex); //NON-NLS
                        return fileSystems;
                }
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();

                        // Get all the file systems.
                        List<FileSystem> allFileSystems = new ArrayList<FileSystem>();
                        try {
                                rs = connection.executeQuery(s, "SELECT * FROM tsk_fs_info"); //NON-NLS
                                while (rs.next()) {
                                        TskData.TSK_FS_TYPE_ENUM fsType = TskData.TSK_FS_TYPE_ENUM.valueOf(rs.getInt("fs_type")); //NON-NLS
                                        FileSystem fs = new FileSystem(this, rs.getLong("obj_id"), "", rs.getLong("img_offset"), //NON-NLS
                                                        fsType, rs.getLong("block_size"), rs.getLong("block_count"), //NON-NLS
                                                        rs.getLong("root_inum"), rs.getLong("first_inum"), rs.getLong("last_inum")); //NON-NLS
                                        fs.setParent(null);
                                        allFileSystems.add(fs);
                                }
                        } catch (SQLException ex) {
                                logger.log(Level.SEVERE, "There was a problem while trying to obtain all file systems", ex); //NON-NLS
                        } finally {
                                closeResultSet(rs);
                                rs = null;
                        }

                        // For each file system, find the image to which it belongs by iteratively
                        // climbing the tsk_ojbects hierarchy only taking those file systems
                        // that belong to this image.
                        for (FileSystem fs : allFileSystems) {
                                Long imageID = null;
                                Long currentObjID = fs.getId();
                                while (imageID == null) {
                                        try {
                                                rs = connection.executeQuery(s, "SELECT * FROM tsk_objects WHERE tsk_objects.obj_id = " + currentObjID); //NON-NLS
                                                rs.next();
                                                currentObjID = rs.getLong("par_obj_id"); //NON-NLS
                                                if (rs.getInt("type") == TskData.ObjectType.IMG.getObjectType()) { //NON-NLS
                                                        imageID = rs.getLong("obj_id"); //NON-NLS
                                                }
                                        } catch (SQLException ex) {
                                                logger.log(Level.SEVERE, "There was a problem while trying to obtain this image's file systems", ex); //NON-NLS
                                        } finally {
                                                closeResultSet(rs);
                                                rs = null;
                                        }
                                }

                                // see if imageID is this image'statement ID
                                if (imageID == image.getId()) {
                                        fileSystems.add(fs);
                                }
                        }
                } catch (SQLException ex) {
                        logger.log(Level.SEVERE, "Error getting case database connection", ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
                return fileSystems;
        }

        List<Content> getImageChildren(Image img) throws TskCoreException {
                Collection<ObjectInfo> childInfos = getChildrenInfo(img);
                List<Content> children = new ArrayList<Content>();
                for (ObjectInfo info : childInfos) {
                        if (info.type == ObjectType.VS) {
                                children.add(getVolumeSystemById(info.id, img));
                        } else if (info.type == ObjectType.FS) {
                                children.add(getFileSystemById(info.id, img));
                        } else if (info.type == ObjectType.ABSTRACTFILE) {
                                AbstractFile f = getAbstractFileById(info.id);
                                if (f != null) {
                                        children.add(f);
                                }
                        } else {
                                throw new TskCoreException("Image has child of invalid type: " + info.type);
                        }
                }
                return children;
        }

        List<Long> getImageChildrenIds(Image img) throws TskCoreException {
                Collection<ObjectInfo> childInfos = getChildrenInfo(img);
                List<Long> children = new ArrayList<Long>();
                for (ObjectInfo info : childInfos) {
                        if (info.type == ObjectType.VS
                                        || info.type == ObjectType.FS
                                        || info.type == ObjectType.ABSTRACTFILE) {
                                children.add(info.id);
                        } else {
                                throw new TskCoreException("Image has child of invalid type: " + info.type);
                        }
                }
                return children;
        }

        List<Content> getVolumeSystemChildren(VolumeSystem vs) throws TskCoreException {
                Collection<ObjectInfo> childInfos = getChildrenInfo(vs);
                List<Content> children = new ArrayList<Content>();
                for (ObjectInfo info : childInfos) {
                        if (null != info.type) {
                                switch (info.type) {
                                        case VOL:
                                                children.add(getVolumeById(info.id, vs));
                                                break;
                                        case ABSTRACTFILE:
                                                AbstractFile f = getAbstractFileById(info.id);
                                                if (f != null) {
                                                        children.add(f);
                                                }
                                                break;
                                        default:
                                                throw new TskCoreException("VolumeSystem has child of invalid type: " + info.type);
                                }
                        }
                }
                return children;
        }

        List<Long> getVolumeSystemChildrenIds(VolumeSystem vs) throws TskCoreException {
                Collection<ObjectInfo> childInfos = getChildrenInfo(vs);
                List<Long> children = new ArrayList<Long>();
                for (ObjectInfo info : childInfos) {
                        if (info.type == ObjectType.VOL || info.type == ObjectType.ABSTRACTFILE) {
                                children.add(info.id);
                        } else {
                                throw new TskCoreException("VolumeSystem has child of invalid type: " + info.type);
                        }
                }
                return children;
        }

        List<Content> getVolumeChildren(Volume vol) throws TskCoreException {
                Collection<ObjectInfo> childInfos = getChildrenInfo(vol);
                List<Content> children = new ArrayList<Content>();
                for (ObjectInfo info : childInfos) {
                        if (null != info.type) {
                                switch (info.type) {
                                        case FS:
                                                children.add(getFileSystemById(info.id, vol));
                                                break;
                                        case ABSTRACTFILE:
                                                AbstractFile f = getAbstractFileById(info.id);
                                                if (f != null) {
                                                        children.add(f);
                                                }
                                                break;
                                        default:
                                                throw new TskCoreException("Volume has child of invalid type: " + info.type);
                                }
                        }
                }
                return children;
        }

        List<Long> getVolumeChildrenIds(Volume vol) throws TskCoreException {
                final Collection<ObjectInfo> childInfos = getChildrenInfo(vol);
                final List<Long> children = new ArrayList<Long>();
                for (ObjectInfo info : childInfos) {
                        if (info.type == ObjectType.FS || info.type == ObjectType.ABSTRACTFILE) {
                                children.add(info.id);
                        } else {
                                throw new TskCoreException("Volume has child of invalid type: " + info.type);
                        }
                }
                return children;
        }

        public Image addImageInfo(long deviceObjId, List<String> imageFilePaths, String timeZone) throws TskCoreException {
                long imageId = this.caseHandle.addImageInfo(deviceObjId, imageFilePaths, timeZone);
                return getImageById(imageId);
        }

        public Map<Long, List<String>> getImagePaths() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s1 = null;
                Statement s2 = null;
                ResultSet rs1 = null;
                ResultSet rs2 = null;
                try {
                        s1 = connection.createStatement();
                        rs1 = connection.executeQuery(s1, "SELECT obj_id FROM tsk_image_info"); //NON-NLS
                        s2 = connection.createStatement();
                        Map<Long, List<String>> imgPaths = new LinkedHashMap<Long, List<String>>();
                        while (rs1.next()) {
                                long obj_id = rs1.getLong("obj_id"); //NON-NLS
                                rs2 = connection.executeQuery(s2, "SELECT * FROM tsk_image_names WHERE obj_id = " + obj_id); //NON-NLS
                                List<String> paths = new ArrayList<String>();
                                while (rs2.next()) {
                                        paths.add(rs2.getString("name"));
                                }
                                rs2.close();
                                rs2 = null;
                                imgPaths.put(obj_id, paths);
                        }
                        return imgPaths;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting image paths.", ex);
                } finally {
                        closeResultSet(rs2);
                        closeStatement(s2);
                        closeResultSet(rs1);
                        closeStatement(s1);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<Image> getImages() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT obj_id FROM tsk_image_info"); //NON-NLS
                        Collection<Long> imageIDs = new ArrayList<Long>();
                        while (rs.next()) {
                                imageIDs.add(rs.getLong("obj_id")); //NON-NLS
                        }
                        List<Image> images = new ArrayList<Image>();
                        for (long id : imageIDs) {
                                images.add(getImageById(id));
                        }
                        return images;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error retrieving images.", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public void setImagePaths(long obj_id, List<String> paths) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                Statement statement = null;
                try {
                        connection.beginTransaction();
                        statement = connection.createStatement();
                        connection.executeUpdate(statement, "DELETE FROM tsk_image_names WHERE obj_id = " + obj_id); //NON-NLS
                        for (int i = 0; i < paths.size(); i++) {
                                connection.executeUpdate(statement, "INSERT INTO tsk_image_names VALUES (" + obj_id + ", '" + paths.get(i) + "', " + i + ")"); //NON-NLS
                        }
                        connection.commitTransaction();
                } catch (SQLException ex) {
                        connection.rollbackTransaction();
                        throw new TskCoreException("Error updating image paths.", ex);
                } finally {
                        closeStatement(statement);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        private List<AbstractFile> resultSetToAbstractFiles(ResultSet rs, CaseDbConnection connection) throws SQLException {
                ArrayList<AbstractFile> results = new ArrayList<AbstractFile>();
                try {
                        while (rs.next()) {
                                final short type = rs.getShort("type"); //NON-NLS
                                if (type == TSK_DB_FILES_TYPE_ENUM.FS.getFileType()) {
                                        FsContent result;
                                        if (rs.getShort("meta_type") == TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_DIR.getValue()) { //NON-NLS
                                                result = directory(rs, null);
                                        } else {
                                                result = file(rs, null);
                                        }
                                        results.add(result);
                                } else if (type == TSK_DB_FILES_TYPE_ENUM.VIRTUAL_DIR.getFileType()) {
                                        final VirtualDirectory virtDir = virtualDirectory(rs);
                                        results.add(virtDir);
                                } else if (type == TSK_DB_FILES_TYPE_ENUM.UNALLOC_BLOCKS.getFileType()
                                                || type == TSK_DB_FILES_TYPE_ENUM.UNUSED_BLOCKS.getFileType()
                                                || type == TSK_DB_FILES_TYPE_ENUM.CARVED.getFileType()) {
                                        TSK_DB_FILES_TYPE_ENUM atype = TSK_DB_FILES_TYPE_ENUM.valueOf(type);
                                        String parentPath = rs.getString("parent_path"); //NON-NLS
                                        if (parentPath == null) {
                                                parentPath = "/"; //NON-NLS
                                        }
                                        LayoutFile lf = new LayoutFile(this,
                                                        rs.getLong("obj_id"), //NON-NLS
                                                        rs.getLong("data_source_obj_id"),
                                                        rs.getString("name"), //NON-NLS
                                                        atype,
                                                        TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")), TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")), //NON-NLS
                                                        TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), rs.getShort("meta_flags"), //NON-NLS
                                                        rs.getLong("size"), //NON-NLS
                                                        rs.getString("md5"), FileKnown.valueOf(rs.getByte("known")), parentPath, rs.getString("mime_type")); //NON-NLS
                                        results.add(lf);
                                } else if (type == TSK_DB_FILES_TYPE_ENUM.DERIVED.getFileType()) {
                                        final DerivedFile df;
                                        df = derivedFile(rs, connection, AbstractContent.UNKNOWN_ID);
                                        results.add(df);
                                } else if (type == TSK_DB_FILES_TYPE_ENUM.LOCAL.getFileType()) {
                                        final LocalFile lf;
                                        lf = localFile(rs, connection, AbstractContent.UNKNOWN_ID);
                                        results.add(lf);
                                } else if (type == TSK_DB_FILES_TYPE_ENUM.SLACK.getFileType()) {
                                        final SlackFile sf = slackFile(rs, null);
                                        results.add(sf);
                                }
                        } //end for each resultSet
                } catch (SQLException e) {
                        logger.log(Level.SEVERE, "Error getting abstract files from result set", e); //NON-NLS
                }

                return results;
        }

        // This following methods generate AbstractFile objects from a ResultSet
        org.sleuthkit.datamodel.File file(ResultSet rs, FileSystem fs) throws SQLException {
                org.sleuthkit.datamodel.File f = new org.sleuthkit.datamodel.File(this, rs.getLong("obj_id"), //NON-NLS
                                rs.getLong("data_source_obj_id"), rs.getLong("fs_obj_id"), //NON-NLS
                                TskData.TSK_FS_ATTR_TYPE_ENUM.valueOf(rs.getShort("attr_type")), //NON-NLS
                                rs.getInt("attr_id"), rs.getString("name"), rs.getLong("meta_addr"), rs.getInt("meta_seq"), //NON-NLS
                                TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")), //NON-NLS
                                TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")), //NON-NLS
                                TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), //NON-NLS
                                rs.getShort("meta_flags"), rs.getLong("size"), //NON-NLS
                                rs.getLong("ctime"), rs.getLong("crtime"), rs.getLong("atime"), rs.getLong("mtime"), //NON-NLS
                                (short) rs.getInt("mode"), rs.getInt("uid"), rs.getInt("gid"), //NON-NLS
                                rs.getString("md5"), FileKnown.valueOf(rs.getByte("known")), //NON-NLS
                                rs.getString("parent_path"), rs.getString("mime_type")); //NON-NLS
                f.setFileSystem(fs);
                return f;
        }

        Directory directory(ResultSet rs, FileSystem fs) throws SQLException {
                Directory dir = new Directory(this, rs.getLong("obj_id"), rs.getLong("data_source_obj_id"), rs.getLong("fs_obj_id"), //NON-NLS
                                TskData.TSK_FS_ATTR_TYPE_ENUM.valueOf(rs.getShort("attr_type")), //NON-NLS
                                rs.getInt("attr_id"), rs.getString("name"), rs.getLong("meta_addr"), rs.getInt("meta_seq"), //NON-NLS
                                TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")), //NON-NLS
                                TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")), //NON-NLS
                                TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), //NON-NLS
                                rs.getShort("meta_flags"), rs.getLong("size"), //NON-NLS
                                rs.getLong("ctime"), rs.getLong("crtime"), rs.getLong("atime"), rs.getLong("mtime"), //NON-NLS
                                rs.getShort("mode"), rs.getInt("uid"), rs.getInt("gid"), //NON-NLS
                                rs.getString("md5"), FileKnown.valueOf(rs.getByte("known")), //NON-NLS
                                rs.getString("parent_path")); //NON-NLS
                dir.setFileSystem(fs);
                return dir;
        }

        VirtualDirectory virtualDirectory(ResultSet rs) throws SQLException {
                String parentPath = rs.getString("parent_path"); //NON-NLS
                if (parentPath == null) {
                        parentPath = "";
                }
                final VirtualDirectory vd = new VirtualDirectory(this, rs.getLong("obj_id"), //NON-NLS
                                rs.getLong("data_source_obj_id"), rs.getString("name"), //NON-NLS
                                TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")), //NON-NLS
                                TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")), //NON-NLS
                                TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), //NON-NLS
                                rs.getShort("meta_flags"), rs.getString("md5"), //NON-NLS
                                FileKnown.valueOf(rs.getByte("known")), parentPath); //NON-NLS
                return vd;
        }

        DerivedFile derivedFile(ResultSet rs, CaseDbConnection connection, long parentId) throws SQLException {
                boolean hasLocalPath = rs.getBoolean("has_path"); //NON-NLS
                long objId = rs.getLong("obj_id"); //NON-NLS
                String localPath = null;
                TskData.EncodingType encodingType = TskData.EncodingType.NONE;
                if (hasLocalPath) {
                        ResultSet rsFilePath = null;
                        try {
                                PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_LOCAL_PATH_AND_ENCODING_FOR_FILE);
                                statement.clearParameters();
                                statement.setLong(1, objId);
                                rsFilePath = connection.executeQuery(statement);
                                if (rsFilePath.next()) {
                                        localPath = rsFilePath.getString("path");
                                        encodingType = TskData.EncodingType.valueOf(rsFilePath.getInt("encoding_type"));
                                }
                        } catch (SQLException ex) {
                                logger.log(Level.SEVERE, "Error getting encoding type for file " + objId, ex); //NON-NLS
                        } finally {
                                closeResultSet(rsFilePath);
                        }
                }
                String parentPath = rs.getString("parent_path"); //NON-NLS
                if (parentPath == null) {
                        parentPath = "";
                }
                final DerivedFile df = new DerivedFile(this, objId, rs.getLong("data_source_obj_id"),
                                rs.getString("name"), //NON-NLS
                                TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")), //NON-NLS
                                TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")), //NON-NLS
                                TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), rs.getShort("meta_flags"), //NON-NLS
                                rs.getLong("size"), //NON-NLS
                                rs.getLong("ctime"), rs.getLong("crtime"), rs.getLong("atime"), rs.getLong("mtime"), //NON-NLS
                                rs.getString("md5"), FileKnown.valueOf(rs.getByte("known")), //NON-NLS
                                parentPath, localPath, parentId, rs.getString("mime_type"),
                                encodingType);
                return df;
        }

        LocalFile localFile(ResultSet rs, CaseDbConnection connection, long parentId) throws SQLException {
                long objId = rs.getLong("obj_id"); //NON-NLS
                String localPath = null;
                TskData.EncodingType encodingType = TskData.EncodingType.NONE;
                if (rs.getBoolean("has_path")) {
                        ResultSet rsFilePath = null;
                        try {
                                PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_LOCAL_PATH_AND_ENCODING_FOR_FILE);
                                statement.clearParameters();
                                statement.setLong(1, objId);
                                rsFilePath = connection.executeQuery(statement);
                                if (rsFilePath.next()) {
                                        localPath = rsFilePath.getString("path");
                                        encodingType = TskData.EncodingType.valueOf(rsFilePath.getInt("encoding_type"));
                                }
                        } catch (SQLException ex) {
                                logger.log(Level.SEVERE, "Error getting encoding type for file " + objId, ex); //NON-NLS
                        } finally {
                                closeResultSet(rsFilePath);
                        }
                }
                String parentPath = rs.getString("parent_path"); //NON-NLS
                if (null == parentPath) {
                        parentPath = "";
                }
                LocalFile file = new LocalFile(this, objId, rs.getString("name"), //NON-NLS
                                TSK_DB_FILES_TYPE_ENUM.valueOf(rs.getShort("type")), //NON-NLS
                                TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")), //NON-NLS
                                TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")), //NON-NLS
                                TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), rs.getShort("meta_flags"), //NON-NLS
                                rs.getLong("size"), //NON-NLS
                                rs.getLong("ctime"), rs.getLong("crtime"), rs.getLong("atime"), rs.getLong("mtime"), //NON-NLS
                                rs.getString("mime_type"), rs.getString("md5"), FileKnown.valueOf(rs.getByte("known")), //NON-NLS
                                parentId, parentPath, rs.getLong("data_source_obj_id"),
                                localPath, encodingType);
                return file;
        }

        org.sleuthkit.datamodel.SlackFile slackFile(ResultSet rs, FileSystem fs) throws SQLException {
                org.sleuthkit.datamodel.SlackFile f = new org.sleuthkit.datamodel.SlackFile(this, rs.getLong("obj_id"), //NON-NLS
                                rs.getLong("data_source_obj_id"), rs.getLong("fs_obj_id"), //NON-NLS
                                TskData.TSK_FS_ATTR_TYPE_ENUM.valueOf(rs.getShort("attr_type")), //NON-NLS
                                rs.getInt("attr_id"), rs.getString("name"), rs.getLong("meta_addr"), rs.getInt("meta_seq"), //NON-NLS
                                TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")), //NON-NLS
                                TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")), //NON-NLS
                                TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), //NON-NLS
                                rs.getShort("meta_flags"), rs.getLong("size"), //NON-NLS
                                rs.getLong("ctime"), rs.getLong("crtime"), rs.getLong("atime"), rs.getLong("mtime"), //NON-NLS
                                (short) rs.getInt("mode"), rs.getInt("uid"), rs.getInt("gid"), //NON-NLS
                                rs.getString("md5"), FileKnown.valueOf(rs.getByte("known")), //NON-NLS
                                rs.getString("parent_path"), rs.getString("mime_type")); //NON-NLS
                f.setFileSystem(fs);
                return f;
        }

        List<Content> fileChildren(ResultSet rs, CaseDbConnection connection, long parentId) throws SQLException {
                List<Content> children = new ArrayList<Content>();

                while (rs.next()) {
                        TskData.TSK_DB_FILES_TYPE_ENUM type = TskData.TSK_DB_FILES_TYPE_ENUM.valueOf(rs.getShort("type"));

                        if (null != type) {
                                switch (type) {
                                        case FS:
                                                FsContent result;
                                                if (rs.getShort("meta_type") == TSK_FS_META_TYPE_ENUM.TSK_FS_META_TYPE_DIR.getValue()) {
                                                        result = directory(rs, null);
                                                } else {
                                                        result = file(rs, null);
                                                }
                                                children.add(result);
                                                break;
                                        case VIRTUAL_DIR:
                                                VirtualDirectory virtDir = virtualDirectory(rs);
                                                children.add(virtDir);
                                                break;
                                        case UNALLOC_BLOCKS:
                                        case UNUSED_BLOCKS:
                                        case CARVED: {
                                                String parentPath = rs.getString("parent_path");
                                                if (parentPath == null) {
                                                        parentPath = "";
                                                }
                                                final LayoutFile lf = new LayoutFile(this, rs.getLong("obj_id"),
                                                                rs.getLong("data_source_obj_id"), rs.getString("name"), type,
                                                                TSK_FS_NAME_TYPE_ENUM.valueOf(rs.getShort("dir_type")),
                                                                TSK_FS_META_TYPE_ENUM.valueOf(rs.getShort("meta_type")),
                                                                TSK_FS_NAME_FLAG_ENUM.valueOf(rs.getShort("dir_flags")), rs.getShort("meta_flags"),
                                                                rs.getLong("size"), rs.getString("md5"),
                                                                FileKnown.valueOf(rs.getByte("known")), parentPath, rs.getString("mime_type"));
                                                children.add(lf);
                                                break;
                                        }
                                        case DERIVED:
                                                final DerivedFile df = derivedFile(rs, connection, parentId);
                                                children.add(df);
                                                break;
                                        case LOCAL: {
                                                final LocalFile lf = localFile(rs, connection, parentId);
                                                children.add(lf);
                                                break;
                                        }
                                        case SLACK: {
                                                final SlackFile sf = slackFile(rs, null);
                                                children.add(sf);
                                                break;
                                        }
                                        default:
                                                break;
                                }
                        }
                }
                return children;
        }

        public CaseDbQuery executeQuery(String query) throws TskCoreException {
                return new CaseDbQuery(query);
        }

        @Override
        protected void finalize() throws Throwable {
                try {
                        close();
                } finally {
                        super.finalize();
                }
        }

        public void close() {
                acquireExclusiveLock();
                fileSystemIdMap.clear();

                try {
                        connections.close();
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error closing database connection pool.", ex); //NON-NLS
                }
                try {
                        if (this.caseHandle != null) {
                                this.caseHandle.free();
                                this.caseHandle = null;
                        }
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error freeing case handle.", ex); //NON-NLS
                } finally {
                        releaseExclusiveLock();
                }
        }

        public boolean setKnown(AbstractFile file, FileKnown fileKnown) throws TskCoreException {
                long id = file.getId();
                FileKnown currentKnown = file.getKnown();
                if (currentKnown.compareTo(fileKnown) > 0) {
                        return false;
                }
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                Statement statement = null;
                try {
                        statement = connection.createStatement();
                        connection.executeUpdate(statement, "UPDATE tsk_files " //NON-NLS
                                        + "SET known='" + fileKnown.getFileKnownValue() + "' " //NON-NLS
                                        + "WHERE obj_id=" + id); //NON-NLS
                        file.setKnown(fileKnown);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error setting Known status.", ex);
                } finally {
                        closeStatement(statement);
                        connection.close();
                        releaseExclusiveLock();
                }
                return true;
        }

        public void setFileMIMEType(AbstractFile file, String mimeType) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                Statement statement = null;
                ResultSet rs = null;
                acquireExclusiveLock();
                try {
                        statement = connection.createStatement();
                        connection.executeUpdate(statement, String.format("UPDATE tsk_files SET mime_type = '%s' WHERE obj_id = %d", mimeType, file.getId()));
                        file.setMIMEType(mimeType);
                } catch (SQLException ex) {
                        throw new TskCoreException(String.format("Error setting MIME type for file (obj_id = %s)", file.getId()), ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(statement);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        void setMd5Hash(AbstractFile file, String md5Hash) throws TskCoreException {
                if (md5Hash == null) {
                        return;
                }
                long id = file.getId();
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                try {
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.UPDATE_FILE_MD5);
                        statement.clearParameters();
                        statement.setString(1, md5Hash.toLowerCase());
                        statement.setLong(2, id);
                        connection.executeUpdate(statement);
                        file.setMd5Hash(md5Hash.toLowerCase());
                } catch (SQLException ex) {
                        throw new TskCoreException("Error setting MD5 hash", ex);
                } finally {
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public void setReviewStatus(BlackboardArtifact artifact, BlackboardArtifact.ReviewStatus newStatus) throws TskCoreException {
                if (newStatus == null) {
                        return;
                }
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                Statement statement = null;
                try {
                        statement = connection.createStatement();
                        connection.executeUpdate(statement, "UPDATE blackboard_artifacts "
                                        + " SET review_status_id=" + newStatus.getID()
                                        + " WHERE blackboard_artifacts.artifact_id = " + artifact.getArtifactID());
                } catch (SQLException ex) {
                        throw new TskCoreException("Error setting review status", ex);
                } finally {
                        closeStatement(statement);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public int countFsContentType(TskData.TSK_FS_META_TYPE_ENUM contentType) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        Short contentShort = contentType.getValue();
                        rs = connection.executeQuery(s, "SELECT COUNT(*) AS count FROM tsk_files WHERE meta_type = '" + contentShort.toString() + "'"); //NON-NLS
                        int count = 0;
                        if (rs.next()) {
                                count = rs.getInt("count");
                        }
                        return count;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting number of objects.", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public static String escapeSingleQuotes(String text) {
                String escapedText = null;
                if (text != null) {
                        escapedText = text.replaceAll("'", "''");
                }
                return escapedText;
        }

        public List<AbstractFile> findFilesByMd5(String md5Hash) {
                if (md5Hash == null) {
                        return Collections.<AbstractFile>emptyList();
                }
                CaseDbConnection connection;
                try {
                        connection = connections.getConnection();
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error finding files by md5 hash " + md5Hash, ex); //NON-NLS
                        return Collections.<AbstractFile>emptyList();
                }
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_files WHERE " //NON-NLS
                                        + " md5 = '" + md5Hash.toLowerCase() + "' " //NON-NLS
                                        + "AND size > 0"); //NON-NLS
                        return resultSetToAbstractFiles(rs, connection);
                } catch (SQLException ex) {
                        logger.log(Level.WARNING, "Error querying database.", ex); //NON-NLS
                        return Collections.<AbstractFile>emptyList();
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public boolean allFilesMd5Hashed() {
                CaseDbConnection connection;
                try {
                        connection = connections.getConnection();
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error checking md5 hashing status", ex); //NON-NLS
                        return false;
                }
                boolean allFilesAreHashed = false;
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT COUNT(*) AS count FROM tsk_files " //NON-NLS
                                        + "WHERE dir_type = '" + TskData.TSK_FS_NAME_TYPE_ENUM.REG.getValue() + "' " //NON-NLS
                                        + "AND md5 IS NULL " //NON-NLS
                                        + "AND size > '0'"); //NON-NLS
                        if (rs.next() && rs.getInt("count") == 0) {
                                allFilesAreHashed = true;
                        }
                } catch (SQLException ex) {
                        logger.log(Level.WARNING, "Failed to query whether all files have MD5 hashes", ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
                return allFilesAreHashed;
        }

        public int countFilesMd5Hashed() {
                CaseDbConnection connection;
                try {
                        connection = connections.getConnection();
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error getting database connection for hashed files count", ex); //NON-NLS
                        return 0;
                }
                int count = 0;
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT COUNT(*) AS count FROM tsk_files " //NON-NLS
                                        + "WHERE md5 IS NOT NULL " //NON-NLS
                                        + "AND size > '0'"); //NON-NLS
                        if (rs.next()) {
                                count = rs.getInt("count");
                        }
                } catch (SQLException ex) {
                        logger.log(Level.WARNING, "Failed to query for all the files.", ex); //NON-NLS
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
                return count;

        }

        public void addErrorObserver(ErrorObserver observer) {
                sleuthkitCaseErrorObservers.add(observer);
        }

        public void removeErrorObserver(ErrorObserver observer) {
                int i = sleuthkitCaseErrorObservers.indexOf(observer);
                if (i >= 0) {
                        sleuthkitCaseErrorObservers.remove(i);
                }
        }

        public void submitError(String context, String errorMessage) {
                for (ErrorObserver observer : sleuthkitCaseErrorObservers) {
                        if (observer != null) {
                                try {
                                        observer.receiveError(context, errorMessage);
                                } catch (Exception ex) {
                                        logger.log(Level.SEVERE, "Observer client unable to receive message: {0}, {1}", new Object[]{context, errorMessage, ex});
                                }
                        }
                }
        }

        public List<TagName> getAllTagNames() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM tag_names
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_TAG_NAMES);
                        resultSet = connection.executeQuery(statement);
                        ArrayList<TagName> tagNames = new ArrayList<TagName>();
                        while (resultSet.next()) {
                                tagNames.add(new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"), resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")))); //NON-NLS
                        }
                        return tagNames;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error selecting rows from tag_names table", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<TagName> getTagNamesInUse() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM tag_names WHERE tag_name_id IN (SELECT tag_name_id from content_tags UNION SELECT tag_name_id FROM blackboard_artifact_tags)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_TAG_NAMES_IN_USE);
                        resultSet = connection.executeQuery(statement);
                        ArrayList<TagName> tagNames = new ArrayList<TagName>();
                        while (resultSet.next()) {
                                tagNames.add(new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"), resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")))); //NON-NLS
                        }
                        return tagNames;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error selecting rows from tag_names table", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public TagName addTagName(String displayName, String description, TagName.HTML_COLOR color) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                ResultSet resultSet = null;
                try {
                        // INSERT INTO tag_names (display_name, description, color) VALUES (?, ?, ?)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_TAG_NAME, Statement.RETURN_GENERATED_KEYS);
                        statement.clearParameters();
                        statement.setString(1, displayName);
                        statement.setString(2, description);
                        statement.setString(3, color.getName());
                        connection.executeUpdate(statement);
                        resultSet = statement.getGeneratedKeys();
                        resultSet.next();
                        return new TagName(resultSet.getLong(1), //last_insert_rowid()
                                        displayName, description, color);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error adding row for " + displayName + " tag name to tag_names table", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public ContentTag addContentTag(Content content, TagName tagName, String comment, long beginByteOffset, long endByteOffset) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                ResultSet resultSet = null;
                try {
                        // INSERT INTO content_tags (obj_id, tag_name_id, comment, begin_byte_offset, end_byte_offset) VALUES (?, ?, ?, ?, ?)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_CONTENT_TAG, Statement.RETURN_GENERATED_KEYS);
                        statement.clearParameters();
                        statement.setLong(1, content.getId());
                        statement.setLong(2, tagName.getId());
                        statement.setString(3, comment);
                        statement.setLong(4, beginByteOffset);
                        statement.setLong(5, endByteOffset);
                        connection.executeUpdate(statement);
                        resultSet = statement.getGeneratedKeys();
                        resultSet.next();
                        return new ContentTag(resultSet.getLong(1), //last_insert_rowid()
                                        content, tagName, comment, beginByteOffset, endByteOffset);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error adding row to content_tags table (obj_id = " + content.getId() + ", tag_name_id = " + tagName.getId() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        /*
         * Deletes a row from the content_tags table in the case database. @param
         * tag A ContentTag data transfer object (DTO) for the row to delete.
         * @throws TskCoreException
         */
        public void deleteContentTag(ContentTag tag) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                try {
                        // DELETE FROM content_tags WHERE tag_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.DELETE_CONTENT_TAG);
                        statement.clearParameters();
                        statement.setLong(1, tag.getId());
                        connection.executeUpdate(statement);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error deleting row from content_tags table (id = " + tag.getId() + ")", ex);
                } finally {
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public List<ContentTag> getAllContentTags() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM content_tags INNER JOIN tag_names ON content_tags.tag_name_id = tag_names.tag_name_id
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_CONTENT_TAGS);
                        resultSet = connection.executeQuery(statement);
                        ArrayList<ContentTag> tags = new ArrayList<ContentTag>();
                        while (resultSet.next()) {
                                TagName tagName = new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"),
                                                resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")));  //NON-NLS
                                Content content = getContentById(resultSet.getLong("obj_id")); //NON-NLS
                                tags.add(new ContentTag(resultSet.getLong("tag_id"), content, tagName, resultSet.getString("comment"),
                                                resultSet.getLong("begin_byte_offset"), resultSet.getLong("end_byte_offset")));  //NON-NLS
                        }
                        return tags;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error selecting rows from content_tags table", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public long getContentTagsCountByTagName(TagName tagName) throws TskCoreException {
                if (tagName.getId() == Tag.ID_NOT_SET) {
                        throw new TskCoreException("TagName object is invalid, id not set");
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT COUNT(*) AS count FROM content_tags WHERE tag_name_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.COUNT_CONTENT_TAGS_BY_TAG_NAME);
                        statement.clearParameters();
                        statement.setLong(1, tagName.getId());
                        resultSet = connection.executeQuery(statement);
                        if (resultSet.next()) {
                                return resultSet.getLong("count");
                        } else {
                                throw new TskCoreException("Error getting content_tags row count for tag name (tag_name_id = " + tagName.getId() + ")");
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting content_tags row count for tag name (tag_name_id = " + tagName.getId() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public ContentTag getContentTagByID(long contentTagID) throws TskCoreException {

                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                ContentTag tag = null;
                try {
                        // SELECT * FROM content_tags INNER JOIN tag_names ON content_tags.tag_name_id = tag_names.tag_name_id WHERE tag_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_CONTENT_TAG_BY_ID);
                        statement.clearParameters();
                        statement.setLong(1, contentTagID);
                        resultSet = connection.executeQuery(statement);

                        while (resultSet.next()) {
                                TagName tagName = new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"),
                                                resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")));
                                tag = new ContentTag(resultSet.getLong("tag_id"), getContentById(resultSet.getLong("obj_id")), tagName,
                                                resultSet.getString("comment"), resultSet.getLong("begin_byte_offset"), resultSet.getLong("end_byte_offset"));
                        }
                        resultSet.close();

                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting content tag with id = " + contentTagID, ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
                return tag;
        }

        public List<ContentTag> getContentTagsByTagName(TagName tagName) throws TskCoreException {
                if (tagName.getId() == Tag.ID_NOT_SET) {
                        throw new TskCoreException("TagName object is invalid, id not set");
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM content_tags WHERE tag_name_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_CONTENT_TAGS_BY_TAG_NAME);
                        statement.clearParameters();
                        statement.setLong(1, tagName.getId());
                        resultSet = connection.executeQuery(statement);
                        ArrayList<ContentTag> tags = new ArrayList<ContentTag>();
                        while (resultSet.next()) {
                                ContentTag tag = new ContentTag(resultSet.getLong("tag_id"), getContentById(resultSet.getLong("obj_id")),
                                                tagName, resultSet.getString("comment"), resultSet.getLong("begin_byte_offset"), resultSet.getLong("end_byte_offset"));  //NON-NLS
                                tags.add(tag);
                        }
                        resultSet.close();
                        return tags;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting content_tags rows (tag_name_id = " + tagName.getId() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<ContentTag> getContentTagsByContent(Content content) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM content_tags INNER JOIN tag_names ON content_tags.tag_name_id = tag_names.tag_name_id WHERE content_tags.obj_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_CONTENT_TAGS_BY_CONTENT);
                        statement.clearParameters();
                        statement.setLong(1, content.getId());
                        resultSet = connection.executeQuery(statement);
                        ArrayList<ContentTag> tags = new ArrayList<ContentTag>();
                        while (resultSet.next()) {
                                TagName tagName = new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"),
                                                resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")));  //NON-NLS
                                ContentTag tag = new ContentTag(resultSet.getLong("tag_id"), content, tagName,
                                                resultSet.getString("comment"), resultSet.getLong("begin_byte_offset"), resultSet.getLong("end_byte_offset"));  //NON-NLS
                                tags.add(tag);
                        }
                        return tags;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting content tags data for content (obj_id = " + content.getId() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public BlackboardArtifactTag addBlackboardArtifactTag(BlackboardArtifact artifact, TagName tagName, String comment) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                ResultSet resultSet = null;
                try {
                        // INSERT INTO blackboard_artifact_tags (artifact_id, tag_name_id, comment, begin_byte_offset, end_byte_offset) VALUES (?, ?, ?, ?, ?)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_ARTIFACT_TAG, Statement.RETURN_GENERATED_KEYS);
                        statement.clearParameters();
                        statement.setLong(1, artifact.getArtifactID());
                        statement.setLong(2, tagName.getId());
                        statement.setString(3, comment);
                        connection.executeUpdate(statement);
                        resultSet = statement.getGeneratedKeys();
                        resultSet.next();
                        return new BlackboardArtifactTag(resultSet.getLong(1), //last_insert_rowid()
                                        artifact, getContentById(artifact.getObjectID()), tagName, comment);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error adding row to blackboard_artifact_tags table (obj_id = " + artifact.getArtifactID() + ", tag_name_id = " + tagName.getId() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        /*
         * Deletes a row from the blackboard_artifact_tags table in the case
         * database. @param tag A BlackboardArtifactTag data transfer object (DTO)
         * representing the row to delete. @throws TskCoreException
         */
        public void deleteBlackboardArtifactTag(BlackboardArtifactTag tag) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                try {
                        // DELETE FROM blackboard_artifact_tags WHERE tag_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.DELETE_ARTIFACT_TAG);
                        statement.clearParameters();
                        statement.setLong(1, tag.getId());
                        connection.executeUpdate(statement);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error deleting row from blackboard_artifact_tags table (id = " + tag.getId() + ")", ex);
                } finally {
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public List<BlackboardArtifactTag> getAllBlackboardArtifactTags() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM blackboard_artifact_tags INNER JOIN tag_names ON blackboard_artifact_tags.tag_name_id = tag_names.tag_name_id
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_ARTIFACT_TAGS);
                        resultSet = connection.executeQuery(statement);
                        ArrayList<BlackboardArtifactTag> tags = new ArrayList<BlackboardArtifactTag>();
                        while (resultSet.next()) {
                                TagName tagName = new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"),
                                                resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")));  //NON-NLS
                                BlackboardArtifact artifact = getBlackboardArtifact(resultSet.getLong("artifact_id")); //NON-NLS
                                Content content = getContentById(artifact.getObjectID());
                                BlackboardArtifactTag tag = new BlackboardArtifactTag(resultSet.getLong("tag_id"),
                                                artifact, content, tagName, resultSet.getString("comment"));  //NON-NLS
                                tags.add(tag);
                        }
                        return tags;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error selecting rows from blackboard_artifact_tags table", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public long getBlackboardArtifactTagsCountByTagName(TagName tagName) throws TskCoreException {
                if (tagName.getId() == Tag.ID_NOT_SET) {
                        throw new TskCoreException("TagName object is invalid, id not set");
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT COUNT(*) AS count FROM blackboard_artifact_tags WHERE tag_name_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.COUNT_ARTIFACTS_BY_TAG_NAME);
                        statement.clearParameters();
                        statement.setLong(1, tagName.getId());
                        resultSet = connection.executeQuery(statement);
                        if (resultSet.next()) {
                                return resultSet.getLong("count");
                        } else {
                                throw new TskCoreException("Error getting blackboard_artifact_tags row count for tag name (tag_name_id = " + tagName.getId() + ")");
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifact_content_tags row count for tag name (tag_name_id = " + tagName.getId() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public List<BlackboardArtifactTag> getBlackboardArtifactTagsByTagName(TagName tagName) throws TskCoreException {
                if (tagName.getId() == Tag.ID_NOT_SET) {
                        throw new TskCoreException("TagName object is invalid, id not set");
                }
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM blackboard_artifact_tags WHERE tag_name_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_ARTIFACT_TAGS_BY_TAG_NAME);
                        statement.clearParameters();
                        statement.setLong(1, tagName.getId());
                        resultSet = connection.executeQuery(statement);
                        ArrayList<BlackboardArtifactTag> tags = new ArrayList<BlackboardArtifactTag>();
                        while (resultSet.next()) {
                                BlackboardArtifact artifact = getBlackboardArtifact(resultSet.getLong("artifact_id")); //NON-NLS
                                Content content = getContentById(artifact.getObjectID());
                                BlackboardArtifactTag tag = new BlackboardArtifactTag(resultSet.getLong("tag_id"),
                                                artifact, content, tagName, resultSet.getString("comment"));  //NON-NLS
                                tags.add(tag);
                        }
                        return tags;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifact tags data (tag_name_id = " + tagName.getId() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public BlackboardArtifactTag getBlackboardArtifactTagByID(long artifactTagID) throws TskCoreException {

                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                BlackboardArtifactTag tag = null;
                try {
                        // SELECT * FROM blackboard_artifact_tags INNER JOIN tag_names ON blackboard_artifact_tags.tag_name_id = tag_names.tag_name_id WHERE blackboard_artifact_tags.tag_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_ARTIFACT_TAG_BY_ID);
                        statement.clearParameters();
                        statement.setLong(1, artifactTagID);
                        resultSet = connection.executeQuery(statement);

                        while (resultSet.next()) {
                                TagName tagName = new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"),
                                                resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")));
                                BlackboardArtifact artifact = getBlackboardArtifact(resultSet.getLong("artifact_id")); //NON-NLS
                                Content content = getContentById(artifact.getObjectID());
                                tag = new BlackboardArtifactTag(resultSet.getLong("tag_id"),
                                                artifact, content, tagName, resultSet.getString("comment"));
                        }
                        resultSet.close();

                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifact tag with id = " + artifactTagID, ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
                return tag;
        }

        public List<BlackboardArtifactTag> getBlackboardArtifactTagsByArtifact(BlackboardArtifact artifact) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM blackboard_artifact_tags INNER JOIN tag_names ON blackboard_artifact_tags.tag_name_id = tag_names.tag_name_id WHERE blackboard_artifact_tags.artifact_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_ARTIFACT_TAGS_BY_ARTIFACT);
                        statement.clearParameters();
                        statement.setLong(1, artifact.getArtifactID());
                        resultSet = connection.executeQuery(statement);
                        ArrayList<BlackboardArtifactTag> tags = new ArrayList<BlackboardArtifactTag>();
                        while (resultSet.next()) {
                                TagName tagName = new TagName(resultSet.getLong("tag_name_id"), resultSet.getString("display_name"),
                                                resultSet.getString("description"), TagName.HTML_COLOR.getColorByName(resultSet.getString("color")));  //NON-NLS
                                Content content = getContentById(artifact.getObjectID());
                                BlackboardArtifactTag tag = new BlackboardArtifactTag(resultSet.getLong("tag_id"),
                                                artifact, content, tagName, resultSet.getString("comment"));  //NON-NLS
                                tags.add(tag);
                        }
                        return tags;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting blackboard artifact tags data (artifact_id = " + artifact.getArtifactID() + ")", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public void updateImagePath(String newPath, long objectId) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                try {
                        // UPDATE tsk_image_names SET name = ? WHERE obj_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.UPDATE_IMAGE_PATH);
                        statement.clearParameters();
                        statement.setString(1, newPath);
                        statement.setLong(2, objectId);
                        connection.executeUpdate(statement);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error updating image path in database for object " + objectId, ex);
                } finally {
                        connection.close();
                        releaseSharedLock();
                }
        }

        public Report addReport(String localPath, String sourceModuleName, String reportName) throws TskCoreException {
                // Make sure the local path of the report is in the database directory
                // or one of its subdirectories.
                String relativePath = ""; //NON-NLS
                try {
                        /*
                         * Note: The following call to .relativize() may be dangerous in
                         * case-sensitive operating systems and should be looked at. For
                         * now, we are simply relativizing the paths as all lower case, then
                         * using the length of the result to pull out the appropriate number
                         * of characters from the localPath String.
                         */
                        String casePathLower = getDbDirPath().toLowerCase();
                        String localPathLower = localPath.toLowerCase();
                        int length = new File(casePathLower).toURI().relativize(new File(localPathLower).toURI()).getPath().length();
                        relativePath = new File(localPath.substring(localPathLower.length() - length)).getPath();
                } catch (IllegalArgumentException ex) {
                        String errorMessage = String.format("Local path %s not in the database directory or one of its subdirectories", localPath);
                        throw new TskCoreException(errorMessage, ex);
                }

                // Figure out the create time of the report.
                long createTime = 0;
                try {
                        java.io.File tempFile = new java.io.File(localPath);
                        // Convert to UNIX epoch (seconds, not milliseconds).
                        createTime = tempFile.lastModified() / 1000;
                } catch (Exception ex) {
                        throw new TskCoreException("Could not get create time for report at " + localPath, ex);
                }

                // Write the report data to the database.
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                ResultSet resultSet = null;
                try {
                        // INSERT INTO reports (path, crtime, src_module_name, display_name) VALUES (?, ?, ?, ?)
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_REPORT, Statement.RETURN_GENERATED_KEYS);
                        statement.clearParameters();
                        statement.setString(1, relativePath);
                        statement.setLong(2, createTime);
                        statement.setString(3, sourceModuleName);
                        statement.setString(4, reportName);
                        connection.executeUpdate(statement);
                        resultSet = statement.getGeneratedKeys();
                        resultSet.next();
                        return new Report(resultSet.getLong(1), //last_insert_rowid()
                                        localPath, createTime, sourceModuleName, reportName);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error adding report " + localPath + " to reports table", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        public List<Report> getAllReports() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                try {
                        // SELECT * FROM reports
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_REPORTS);
                        resultSet = connection.executeQuery(statement);
                        ArrayList<Report> reports = new ArrayList<Report>();
                        while (resultSet.next()) {
                                reports.add(new Report(resultSet.getLong("report_id"), //NON-NLS
                                                Paths.get(getDbDirPath(), resultSet.getString("path")).normalize().toString(), //NON-NLS
                                                resultSet.getLong("crtime"), //NON-NLS
                                                resultSet.getString("src_module_name"), //NON-NLS
                                                resultSet.getString("report_name")));  //NON-NLS
                        }
                        return reports;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error querying reports table", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public void deleteReport(Report report) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                try {
                        // DELETE FROM reports WHERE reports.report_id = ?
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.DELETE_REPORT);
                        statement.setLong(1, report.getId());
                        connection.executeUpdate(statement);
                } catch (SQLException ex) {
                        throw new TskCoreException("Error querying reports table", ex);
                } finally {
                        releaseSharedLock();
                }
        }

        private static void closeResultSet(ResultSet resultSet) {
                if (resultSet != null) {
                        try {
                                resultSet.close();
                        } catch (SQLException ex) {
                                logger.log(Level.SEVERE, "Error closing ResultSet", ex); //NON-NLS
                        }
                }
        }

        private static void closeStatement(Statement statement) {
                if (statement != null) {
                        try {
                                statement.close();
                        } catch (SQLException ex) {
                                logger.log(Level.SEVERE, "Error closing Statement", ex); //NON-NLS

                        }
                }
        }

        void setIngestJobEndDateTime(long ingestJobId, long endDateTime) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                try {
                        Statement statement = connection.createStatement();
                        statement.executeUpdate("UPDATE ingest_jobs SET end_date_time=" + endDateTime + " WHERE ingest_job_id=" + ingestJobId + ";");
                } catch (SQLException ex) {
                        throw new TskCoreException("Error updating the end date (ingest_job_id = " + ingestJobId + ".", ex);
                } finally {
                        connection.close();
                        releaseSharedLock();
                }
        }

        void setIngestJobStatus(long ingestJobId, IngestJobStatusType status) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                try {
                        Statement statement = connection.createStatement();
                        statement.executeUpdate("UPDATE ingest_jobs SET status_id=" + status.ordinal() + " WHERE ingest_job_id=" + ingestJobId + ";");
                } catch (SQLException ex) {
                        throw new TskCoreException("Error ingest job status (ingest_job_id = " + ingestJobId + ".", ex);
                } finally {
                        connection.close();
                        releaseSharedLock();
                }
        }

        public final IngestJobInfo addIngestJob(Content dataSource, String hostName, List<IngestModuleInfo> ingestModules, Date jobStart, Date jobEnd, IngestJobStatusType status, String settingsDir) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                ResultSet resultSet = null;
                Statement statement = null;
                try {
                        connection.beginTransaction();
                        statement = connection.createStatement();
                        PreparedStatement insertStatement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_INGEST_JOB, Statement.RETURN_GENERATED_KEYS);
                        insertStatement.setLong(1, dataSource.getId());
                        insertStatement.setString(2, hostName);
                        insertStatement.setLong(3, jobStart.getTime());
                        insertStatement.setLong(4, jobEnd.getTime());
                        insertStatement.setInt(5, status.ordinal());
                        insertStatement.setString(6, settingsDir);
                        connection.executeUpdate(insertStatement);
                        resultSet = insertStatement.getGeneratedKeys();
                        resultSet.next();
                        long id = resultSet.getLong(1); //last_insert_rowid()
                        for (int i = 0; i < ingestModules.size(); i++) {
                                IngestModuleInfo ingestModule = ingestModules.get(i);
                                statement.executeUpdate("INSERT INTO ingest_job_modules (ingest_job_id, ingest_module_id, pipeline_position) "
                                                + "VALUES (" + id + ", " + ingestModule.getIngestModuleId() + ", " + i + ");");
                        }
                        resultSet.close();
                        resultSet = null;
                        connection.commitTransaction();
                        return new IngestJobInfo(id, dataSource.getId(), hostName, jobStart, "", ingestModules, this);
                } catch (SQLException ex) {
                        connection.rollbackTransaction();
                        throw new TskCoreException("Error adding the ingest job.", ex);
                } finally {
                        closeResultSet(resultSet);
                        connection.close();
                        releaseSharedLock();
                }
        }

        public final IngestModuleInfo addIngestModule(String displayName, String factoryClassName, IngestModuleType type, String version) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                ResultSet resultSet = null;
                Statement statement = null;
                String uniqueName = factoryClassName + "-" + displayName + "-" + type.toString() + "-" + version;
                try {
                        statement = connection.createStatement();
                        resultSet = statement.executeQuery("SELECT * FROM ingest_modules WHERE unique_name = '" + uniqueName + "'");
                        if (!resultSet.next()) {
                                resultSet.close();
                                resultSet = null;
                                PreparedStatement insertStatement = connection.getPreparedStatement(PREPARED_STATEMENT.INSERT_INGEST_MODULE, Statement.RETURN_GENERATED_KEYS);
                                insertStatement.setString(1, displayName);
                                insertStatement.setString(2, uniqueName);
                                insertStatement.setInt(3, type.ordinal());
                                insertStatement.setString(4, version);
                                connection.executeUpdate(insertStatement);
                                resultSet = statement.getGeneratedKeys();
                                resultSet.next();
                                long id = resultSet.getLong(1); //last_insert_rowid()
                                resultSet.close();
                                resultSet = null;
                                return new IngestModuleInfo(id, displayName, uniqueName, type, version);
                        } else {
                                return new IngestModuleInfo(resultSet.getInt("ingest_module_id"), resultSet.getString("display_name"),
                                                resultSet.getString("unique_name"), IngestModuleType.fromID(resultSet.getInt("type_id")), resultSet.getString("version"));
                        }
                } catch (SQLException ex) {
                        try {
                                closeStatement(statement);
                                statement = connection.createStatement();
                                resultSet = statement.executeQuery("SELECT * FROM ingest_modules WHERE unique_name = '" + uniqueName + "'");
                                if (resultSet.next()) {
                                        return new IngestModuleInfo(resultSet.getInt("ingest_module_id"), resultSet.getString("display_name"),
                                                        uniqueName, IngestModuleType.fromID(resultSet.getInt("type_id")), resultSet.getString("version"));
                                } else {
                                        throw new TskCoreException("Couldn't add new module to database.", ex);
                                }
                        } catch (SQLException ex1) {
                                throw new TskCoreException("Couldn't add new module to database.", ex1);
                        }
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        public final List<IngestJobInfo> getIngestJobs() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                ResultSet resultSet = null;
                Statement statement = null;
                List<IngestJobInfo> ingestJobs = new ArrayList<IngestJobInfo>();
                try {
                        statement = connection.createStatement();
                        resultSet = statement.executeQuery("SELECT * FROM ingest_jobs");
                        while (resultSet.next()) {
                                ingestJobs.add(new IngestJobInfo(resultSet.getInt("ingest_job_id"), resultSet.getLong("obj_id"),
                                                resultSet.getString("host_name"), new Date(resultSet.getLong("start_date_time")),
                                                new Date(resultSet.getLong("end_date_time")), IngestJobStatusType.fromID(resultSet.getInt("status_id")),
                                                resultSet.getString("settings_dir"), this.getIngestModules(resultSet.getInt("ingest_job_id"), connection), this));
                        }
                        return ingestJobs;
                } catch (SQLException ex) {
                        throw new TskCoreException("Couldn't get the ingest jobs.", ex);
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                        connection.close();
                }
        }

        private List<IngestModuleInfo> getIngestModules(int ingestJobId, CaseDbConnection connection) throws SQLException {
                ResultSet resultSet = null;
                Statement statement = null;
                List<IngestModuleInfo> ingestModules = new ArrayList<IngestModuleInfo>();
                try {
                        statement = connection.createStatement();
                        resultSet = statement.executeQuery("SELECT ingest_job_modules.ingest_module_id AS ingest_module_id, "
                                        + "ingest_job_modules.pipeline_position AS pipeline_position, "
                                        + "ingest_modules.display_name AS display_name, ingest_modules.unique_name AS unique_name, "
                                        + "ingest_modules.type_id AS type_id, ingest_modules.version AS version "
                                        + "FROM ingest_job_modules, ingest_modules "
                                        + "WHERE ingest_job_modules.ingest_job_id = " + ingestJobId + " "
                                        + "AND ingest_modules.ingest_module_id = ingest_job_modules.ingest_module_id "
                                        + "ORDER BY (ingest_job_modules.pipeline_position);");
                        while (resultSet.next()) {
                                ingestModules.add(new IngestModuleInfo(resultSet.getInt("ingest_module_id"), resultSet.getString("display_name"),
                                                resultSet.getString("unique_name"), IngestModuleType.fromID(resultSet.getInt("type_id")), resultSet.getString("version")));
                        }
                        return ingestModules;
                } finally {
                        closeResultSet(resultSet);
                        closeStatement(statement);
                }
        }

        public interface ErrorObserver {

                public enum Context {

                        IMAGE_READ_ERROR("Image File Read Error"),
                        DATABASE_READ_ERROR("Database Read Error");

                        private final String contextString;

                        private Context(String context) {
                                this.contextString = context;
                        }

                        public String getContextString() {
                                return contextString;
                        }
                };

                void receiveError(String context, String errorMessage);
        }

        static class ObjectInfo {

                private long id;
                private TskData.ObjectType type;

                ObjectInfo(long id, ObjectType type) {
                        this.id = id;
                        this.type = type;
                }

                long getId() {
                        return id;
                }

                TskData.ObjectType getType() {
                        return type;
                }
        }

        private interface DbCommand {

                void execute() throws SQLException;
        }

        private enum PREPARED_STATEMENT {

                SELECT_ARTIFACTS_BY_TYPE("SELECT artifact_id, obj_id FROM blackboard_artifacts " //NON-NLS
                                + "WHERE artifact_type_id = ?"), //NON-NLS
                COUNT_ARTIFACTS_OF_TYPE("SELECT COUNT(*) AS count FROM blackboard_artifacts WHERE artifact_type_id = ? AND review_status_id != " + BlackboardArtifact.ReviewStatus.REJECTED.getID()), //NON-NLS
                COUNT_ARTIFACTS_FROM_SOURCE("SELECT COUNT(*) AS count FROM blackboard_artifacts WHERE obj_id = ? AND review_status_id != " + BlackboardArtifact.ReviewStatus.REJECTED.getID()), //NON-NLS
                COUNT_ARTIFACTS_BY_SOURCE_AND_TYPE("SELECT COUNT(*) AS count FROM blackboard_artifacts WHERE obj_id = ? AND artifact_type_id = ? AND review_status_id != " + BlackboardArtifact.ReviewStatus.REJECTED.getID()), //NON-NLS
                SELECT_FILES_BY_PARENT("SELECT tsk_files.* " //NON-NLS
                                + "FROM tsk_objects INNER JOIN tsk_files " //NON-NLS
                                + "ON tsk_objects.obj_id=tsk_files.obj_id " //NON-NLS
                                + "WHERE (tsk_objects.par_obj_id = ? ) " //NON-NLS
                                + "ORDER BY tsk_files.dir_type, LOWER(tsk_files.name)"), //NON-NLS
                SELECT_FILES_BY_PARENT_AND_TYPE("SELECT tsk_files.* " //NON-NLS
                                + "FROM tsk_objects INNER JOIN tsk_files " //NON-NLS
                                + "ON tsk_objects.obj_id=tsk_files.obj_id " //NON-NLS
                                + "WHERE (tsk_objects.par_obj_id = ? AND tsk_files.type = ? ) " //NON-NLS
                                + "ORDER BY tsk_files.dir_type, LOWER(tsk_files.name)"), //NON-NLS
                SELECT_FILE_IDS_BY_PARENT("SELECT tsk_files.obj_id AS obj_id " //NON-NLS
                                + "FROM tsk_objects INNER JOIN tsk_files " //NON-NLS
                                + "ON tsk_objects.obj_id=tsk_files.obj_id " //NON-NLS
                                + "WHERE (tsk_objects.par_obj_id = ?)"), //NON-NLS
                SELECT_FILE_IDS_BY_PARENT_AND_TYPE("SELECT tsk_files.obj_id AS obj_id " //NON-NLS
                                + "FROM tsk_objects INNER JOIN tsk_files " //NON-NLS
                                + "ON tsk_objects.obj_id=tsk_files.obj_id " //NON-NLS
                                + "WHERE (tsk_objects.par_obj_id = ? " //NON-NLS
                                + "AND tsk_files.type = ? )"), //NON-NLS
                SELECT_FILE_BY_ID("SELECT * FROM tsk_files WHERE obj_id = ? LIMIT 1"), //NON-NLS
                INSERT_ARTIFACT("INSERT INTO blackboard_artifacts (artifact_id, obj_id, artifact_type_id, review_status_id) " //NON-NLS
                                + "VALUES (?, ?, ?," + BlackboardArtifact.ReviewStatus.UNDECIDED.getID() + ")"), //NON-NLS
                POSTGRESQL_INSERT_ARTIFACT("INSERT INTO blackboard_artifacts (artifact_id, obj_id, artifact_type_id, review_status_id) " //NON-NLS
                                + "VALUES (DEFAULT, ?, ?," + BlackboardArtifact.ReviewStatus.UNDECIDED.getID() + ")"), //NON-NLS
                INSERT_STRING_ATTRIBUTE("INSERT INTO blackboard_attributes (artifact_id, artifact_type_id, source, context, attribute_type_id, value_type, value_text) " //NON-NLS
                                + "VALUES (?,?,?,?,?,?,?)"), //NON-NLS
                INSERT_BYTE_ATTRIBUTE("INSERT INTO blackboard_attributes (artifact_id, artifact_type_id, source, context, attribute_type_id, value_type, value_byte) " //NON-NLS
                                + "VALUES (?,?,?,?,?,?,?)"), //NON-NLS
                INSERT_INT_ATTRIBUTE("INSERT INTO blackboard_attributes (artifact_id, artifact_type_id, source, context, attribute_type_id, value_type, value_int32) " //NON-NLS
                                + "VALUES (?,?,?,?,?,?,?)"), //NON-NLS
                INSERT_LONG_ATTRIBUTE("INSERT INTO blackboard_attributes (artifact_id, artifact_type_id, source, context, attribute_type_id, value_type, value_int64) " //NON-NLS
                                + "VALUES (?,?,?,?,?,?,?)"), //NON-NLS
                INSERT_DOUBLE_ATTRIBUTE("INSERT INTO blackboard_attributes (artifact_id, artifact_type_id, source, context, attribute_type_id, value_type, value_double) " //NON-NLS
                                + "VALUES (?,?,?,?,?,?,?)"), //NON-NLS
                SELECT_FILES_BY_DATA_SOURCE_AND_NAME("SELECT * FROM tsk_files WHERE LOWER(name) LIKE LOWER(?) AND LOWER(name) NOT LIKE LOWER('%journal%') AND data_source_obj_id = ?"), //NON-NLS
                SELECT_FILES_BY_DATA_SOURCE_AND_PARENT_PATH_AND_NAME("SELECT * FROM tsk_files WHERE LOWER(name) LIKE LOWER(?) AND LOWER(name) NOT LIKE LOWER('%journal%') AND LOWER(parent_path) LIKE LOWER(?) AND data_source_obj_id = ?"), //NON-NLS
                UPDATE_FILE_MD5("UPDATE tsk_files SET md5 = ? WHERE obj_id = ?"), //NON-NLS
                SELECT_LOCAL_PATH_FOR_FILE("SELECT path FROM tsk_files_path WHERE obj_id = ?"), //NON-NLS
                SELECT_ENCODING_FOR_FILE("SELECT encoding_type FROM tsk_files_path WHERE obj_id = ?"), // NON-NLS
                SELECT_LOCAL_PATH_AND_ENCODING_FOR_FILE("SELECT path, encoding_type FROM tsk_files_path WHERE obj_id = ?"), // NON_NLS
                SELECT_PATH_FOR_FILE("SELECT parent_path FROM tsk_files WHERE obj_id = ?"), //NON-NLS
                SELECT_FILE_NAME("SELECT name FROM tsk_files WHERE obj_id = ?"), //NON-NLS
                SELECT_DERIVED_FILE("SELECT derived_id, rederive FROM tsk_files_derived WHERE obj_id = ?"), //NON-NLS
                SELECT_FILE_DERIVATION_METHOD("SELECT tool_name, tool_version, other FROM tsk_files_derived_method WHERE derived_id = ?"), //NON-NLS
                SELECT_MAX_OBJECT_ID("SELECT MAX(obj_id) AS max_obj_id FROM tsk_objects"), //NON-NLS
                INSERT_OBJECT("INSERT INTO tsk_objects (par_obj_id, type) VALUES (?, ?)"), //NON-NLS
                INSERT_FILE("INSERT INTO tsk_files (obj_id, fs_obj_id, name, type, has_path, dir_type, meta_type, dir_flags, meta_flags, size, ctime, crtime, atime, mtime, parent_path, data_source_obj_id) " //NON-NLS
                                + "VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"), //NON-NLS
                INSERT_LAYOUT_FILE("INSERT INTO tsk_file_layout (obj_id, byte_start, byte_len, sequence) " //NON-NLS
                                + "VALUES (?, ?, ?, ?)"), //NON-NLS
                INSERT_LOCAL_PATH("INSERT INTO tsk_files_path (obj_id, path, encoding_type) VALUES (?, ?, ?)"), //NON-NLS
                COUNT_CHILD_OBJECTS_BY_PARENT("SELECT COUNT(obj_id) AS count FROM tsk_objects WHERE par_obj_id = ?"), //NON-NLS
                SELECT_FILE_SYSTEM_BY_OBJECT("SELECT fs_obj_id from tsk_files WHERE obj_id=?"), //NON-NLS
                SELECT_TAG_NAMES("SELECT * FROM tag_names"), //NON-NLS
                SELECT_TAG_NAMES_IN_USE("SELECT * FROM tag_names " //NON-NLS
                                + "WHERE tag_name_id IN " //NON-NLS
                                + "(SELECT tag_name_id from content_tags UNION SELECT tag_name_id FROM blackboard_artifact_tags)"), //NON-NLS
                INSERT_TAG_NAME("INSERT INTO tag_names (display_name, description, color) VALUES (?, ?, ?)"), //NON-NLS
                INSERT_CONTENT_TAG("INSERT INTO content_tags (obj_id, tag_name_id, comment, begin_byte_offset, end_byte_offset) VALUES (?, ?, ?, ?, ?)"), //NON-NLS
                DELETE_CONTENT_TAG("DELETE FROM content_tags WHERE tag_id = ?"), //NON-NLS
                COUNT_CONTENT_TAGS_BY_TAG_NAME("SELECT COUNT(*) AS count FROM content_tags WHERE tag_name_id = ?"), //NON-NLS
                SELECT_CONTENT_TAGS("SELECT * FROM content_tags INNER JOIN tag_names ON content_tags.tag_name_id = tag_names.tag_name_id"), //NON-NLS
                SELECT_CONTENT_TAGS_BY_TAG_NAME("SELECT * FROM content_tags WHERE tag_name_id = ?"), //NON-NLS
                SELECT_CONTENT_TAG_BY_ID("SELECT * FROM content_tags INNER JOIN tag_names ON content_tags.tag_name_id = tag_names.tag_name_id WHERE tag_id = ?"), //NON-NLS
                SELECT_CONTENT_TAGS_BY_CONTENT("SELECT * FROM content_tags INNER JOIN tag_names ON content_tags.tag_name_id = tag_names.tag_name_id WHERE content_tags.obj_id = ?"), //NON-NLS
                INSERT_ARTIFACT_TAG("INSERT INTO blackboard_artifact_tags (artifact_id, tag_name_id, comment) VALUES (?, ?, ?)"), //NON-NLS
                DELETE_ARTIFACT_TAG("DELETE FROM blackboard_artifact_tags WHERE tag_id = ?"), //NON-NLS
                SELECT_ARTIFACT_TAGS("SELECT * FROM blackboard_artifact_tags INNER JOIN tag_names ON blackboard_artifact_tags.tag_name_id = tag_names.tag_name_id"), //NON-NLS
                COUNT_ARTIFACTS_BY_TAG_NAME("SELECT COUNT(*) AS count FROM blackboard_artifact_tags WHERE tag_name_id = ?"), //NON-NLS
                SELECT_ARTIFACT_TAGS_BY_TAG_NAME("SELECT * FROM blackboard_artifact_tags WHERE tag_name_id = ?"), //NON-NLS
                SELECT_ARTIFACT_TAG_BY_ID("SELECT * FROM blackboard_artifact_tags INNER JOIN tag_names ON blackboard_artifact_tags.tag_name_id = tag_names.tag_name_id  WHERE blackboard_artifact_tags.tag_id = ?"), //NON-NLS
                SELECT_ARTIFACT_TAGS_BY_ARTIFACT("SELECT * FROM blackboard_artifact_tags INNER JOIN tag_names ON blackboard_artifact_tags.tag_name_id = tag_names.tag_name_id WHERE blackboard_artifact_tags.artifact_id = ?"), //NON-NLS
                SELECT_REPORTS("SELECT * FROM reports"), //NON-NLS
                INSERT_REPORT("INSERT INTO reports (path, crtime, src_module_name, report_name) VALUES (?, ?, ?, ?)"), //NON-NLS
                DELETE_REPORT("DELETE FROM reports WHERE reports.report_id = ?"), //NON-NLS
                INSERT_INGEST_JOB("INSERT INTO ingest_jobs (obj_id, host_name, start_date_time, end_date_time, status_id, settings_dir) VALUES (?, ?, ?, ?, ?, ?)"), //NON-NLS
                INSERT_INGEST_MODULE("INSERT INTO ingest_modules (display_name, unique_name, type_id, version) VALUES(?, ?, ?, ?)"), //NON-NLS
                SELECT_ATTR_BY_VALUE_BYTE("SELECT source FROM blackboard_attributes WHERE artifact_id = ? AND attribute_type_id = ? AND value_type = 4 AND value_byte = ?"), //NON-NLS
                UPDATE_ATTR_BY_VALUE_BYTE("UPDATE blackboard_attributes SET source = ? WHERE artifact_id = ? AND attribute_type_id = ? AND value_type = 4 AND value_byte = ?"), //NON-NLS
                UPDATE_IMAGE_PATH("UPDATE tsk_image_names SET name = ? WHERE obj_id = ?"); // NON-NLS 

                private final String sql;

                private PREPARED_STATEMENT(String sql) {
                        this.sql = sql;
                }

                String getSQL() {
                        return sql;
                }
        }

        abstract private class ConnectionPool {

                private PooledDataSource pooledDataSource;

                public ConnectionPool() {
                        pooledDataSource = null;
                }

                CaseDbConnection getConnection() throws TskCoreException {
                        if (pooledDataSource == null) {
                                throw new TskCoreException("Error getting case database connection - case is closed");
                        }
                        try {
                                return getPooledConnection();
                        } catch (SQLException exp) {
                                throw new TskCoreException(exp.getMessage());
                        }
                }

                void close() throws TskCoreException {
                        if (pooledDataSource != null) {
                                try {
                                        pooledDataSource.close();
                                } catch (SQLException exp) {
                                        throw new TskCoreException(exp.getMessage());
                                } finally {
                                        pooledDataSource = null;
                                }
                        }
                }

                abstract CaseDbConnection getPooledConnection() throws SQLException;

                public PooledDataSource getPooledDataSource() {
                        return pooledDataSource;
                }

                public void setPooledDataSource(PooledDataSource pooledDataSource) {
                        this.pooledDataSource = pooledDataSource;
                }
        }

        private final class SQLiteConnections extends ConnectionPool {

                private final Map<String, String> configurationOverrides = new HashMap<String, String>();

                SQLiteConnections(String dbPath) throws SQLException {
                        configurationOverrides.put("acquireIncrement", "2");
                        configurationOverrides.put("initialPoolSize", "5");
                        configurationOverrides.put("maxPoolSize", "20");
                        configurationOverrides.put("minPoolSize", "5");
                        configurationOverrides.put("maxStatements", "100");
                        configurationOverrides.put("maxStatementsPerConnection", "20");

                        SQLiteConfig config = new SQLiteConfig();
                        config.setSynchronous(SQLiteConfig.SynchronousMode.OFF); // Reduce I/O operations, we have no OS crash recovery anyway.
                        config.setReadUncommited(true);
                        config.enforceForeignKeys(true); // Enforce foreign key constraints.
                        SQLiteDataSource unpooled = new SQLiteDataSource(config);
                        unpooled.setUrl("jdbc:sqlite:" + dbPath);
                        setPooledDataSource((PooledDataSource) DataSources.pooledDataSource(unpooled, configurationOverrides));
                }

                @Override
                public CaseDbConnection getPooledConnection() throws SQLException {
                        return new SQLiteConnection(getPooledDataSource().getConnection());
                }
        }

        private final class PostgreSQLConnections extends ConnectionPool {

                PostgreSQLConnections(String host, int port, String dbName, String userName, String password) throws PropertyVetoException, UnsupportedEncodingException {
                        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();
                        comboPooledDataSource.setDriverClass("org.postgresql.Driver"); //loads the jdbc driver
                        comboPooledDataSource.setJdbcUrl("jdbc:postgresql://" + host + ":" + port + "/"
                                        + URLEncoder.encode(dbName, StandardCharsets.UTF_8.toString()));
                        comboPooledDataSource.setUser(userName);
                        comboPooledDataSource.setPassword(password);
                        comboPooledDataSource.setAcquireIncrement(2);
                        comboPooledDataSource.setInitialPoolSize(5);
                        comboPooledDataSource.setMaxPoolSize(20);
                        comboPooledDataSource.setMinPoolSize(5);
                        comboPooledDataSource.setMaxStatements(100);
                        comboPooledDataSource.setMaxStatementsPerConnection(20);
                        setPooledDataSource(comboPooledDataSource);
                }

                @Override
                public CaseDbConnection getPooledConnection() throws SQLException {
                        return new PostgreSQLConnection(getPooledDataSource().getConnection());
                }
        }

        private abstract class CaseDbConnection {

                static final int SLEEP_LENGTH_IN_MILLISECONDS = 5000;

                final class CreateStatement implements DbCommand {

                        private final Connection connection;
                        private Statement statement = null;

                        CreateStatement(Connection connection) {
                                this.connection = connection;
                        }

                        Statement getStatement() {
                                return statement;
                        }

                        @Override
                        public void execute() throws SQLException {
                                statement = connection.createStatement();
                        }
                }

                final class SetAutoCommit implements DbCommand {

                        private final Connection connection;
                        private final boolean mode;

                        SetAutoCommit(Connection connection, boolean mode) {
                                this.connection = connection;
                                this.mode = mode;
                        }

                        @Override
                        public void execute() throws SQLException {
                                connection.setAutoCommit(mode);
                        }
                }

                final class Commit implements DbCommand {

                        private final Connection connection;

                        Commit(Connection connection) {
                                this.connection = connection;
                        }

                        @Override
                        public void execute() throws SQLException {
                                connection.commit();
                        }
                }

                final class ExecuteQuery implements DbCommand {

                        private final Statement statement;
                        private final String query;
                        private ResultSet resultSet;

                        ExecuteQuery(Statement statement, String query) {
                                this.statement = statement;
                                this.query = query;
                        }

                        ResultSet getResultSet() {
                                return resultSet;
                        }

                        @Override
                        public void execute() throws SQLException {
                                resultSet = statement.executeQuery(query);
                        }
                }

                final class ExecutePreparedStatementQuery implements DbCommand {

                        private final PreparedStatement preparedStatement;
                        private ResultSet resultSet;

                        ExecutePreparedStatementQuery(PreparedStatement preparedStatement) {
                                this.preparedStatement = preparedStatement;
                        }

                        ResultSet getResultSet() {
                                return resultSet;
                        }

                        @Override
                        public void execute() throws SQLException {
                                resultSet = preparedStatement.executeQuery();
                        }
                }

                final class ExecutePreparedStatementUpdate implements DbCommand {

                        private final PreparedStatement preparedStatement;

                        ExecutePreparedStatementUpdate(PreparedStatement preparedStatement) {
                                this.preparedStatement = preparedStatement;
                        }

                        @Override
                        public void execute() throws SQLException {
                                preparedStatement.executeUpdate();
                        }
                }

                final class ExecuteStatementUpdate implements DbCommand {

                        private final Statement statement;
                        private final String updateCommand;

                        ExecuteStatementUpdate(Statement statement, String updateCommand) {
                                this.statement = statement;
                                this.updateCommand = updateCommand;
                        }

                        @Override
                        public void execute() throws SQLException {
                                statement.executeUpdate(updateCommand);
                        }
                }

                final class ExecuteStatementUpdateGenerateKeys implements DbCommand {

                        private final Statement statement;
                        private final int generateKeys;
                        private final String updateCommand;

                        ExecuteStatementUpdateGenerateKeys(Statement statement, String updateCommand, int generateKeys) {
                                this.statement = statement;
                                this.generateKeys = generateKeys;
                                this.updateCommand = updateCommand;
                        }

                        @Override
                        public void execute() throws SQLException {
                                statement.executeUpdate(updateCommand, generateKeys);
                        }
                }

                final class PrepareStatement implements DbCommand {

                        private final Connection connection;
                        private final String input;
                        private PreparedStatement preparedStatement = null;

                        PrepareStatement(Connection connection, String input) {
                                this.connection = connection;
                                this.input = input;
                        }

                        PreparedStatement getPreparedStatement() {
                                return preparedStatement;
                        }

                        @Override
                        public void execute() throws SQLException {
                                preparedStatement = connection.prepareStatement(input);
                        }
                }

                final class PrepareStatementGenerateKeys implements DbCommand {

                        private final Connection connection;
                        private final String input;
                        private final int generateKeys;
                        private PreparedStatement preparedStatement = null;

                        PrepareStatementGenerateKeys(Connection connection, String input, int generateKeysInput) {
                                this.connection = connection;
                                this.input = input;
                                this.generateKeys = generateKeysInput;
                        }

                        PreparedStatement getPreparedStatement() {
                                return preparedStatement;
                        }

                        @Override
                        public void execute() throws SQLException {
                                preparedStatement = connection.prepareStatement(input, generateKeys);
                        }
                }

                abstract void executeCommand(DbCommand command) throws SQLException;

                private final Connection connection;
                private final Map<PREPARED_STATEMENT, PreparedStatement> preparedStatements;

                CaseDbConnection(Connection connection) {
                        this.connection = connection;
                        preparedStatements = new EnumMap<PREPARED_STATEMENT, PreparedStatement>(PREPARED_STATEMENT.class);
                }

                boolean isOpen() {
                        return this.connection != null;
                }

                PreparedStatement getPreparedStatement(PREPARED_STATEMENT statementKey) throws SQLException {
                        return getPreparedStatement(statementKey, Statement.NO_GENERATED_KEYS);
                }

                PreparedStatement getPreparedStatement(PREPARED_STATEMENT statementKey, int generateKeys) throws SQLException {
                        // Lazy statement preparation.
                        PreparedStatement statement;
                        if (this.preparedStatements.containsKey(statementKey)) {
                                statement = this.preparedStatements.get(statementKey);
                        } else {
                                statement = prepareStatement(statementKey.getSQL(), generateKeys);
                                this.preparedStatements.put(statementKey, statement);
                        }
                        return statement;
                }

                PreparedStatement prepareStatement(String sqlStatement, int generateKeys) throws SQLException {
                        PrepareStatement prepareStatement = new PrepareStatement(this.getConnection(), sqlStatement);
                        executeCommand(prepareStatement);
                        return prepareStatement.getPreparedStatement();
                }

                Statement createStatement() throws SQLException {
                        CreateStatement createStatement = new CreateStatement(this.connection);
                        executeCommand(createStatement);
                        return createStatement.getStatement();
                }

                void beginTransaction() throws SQLException {
                        SetAutoCommit setAutoCommit = new SetAutoCommit(connection, false);
                        executeCommand(setAutoCommit);
                }

                void commitTransaction() throws SQLException {
                        Commit commit = new Commit(connection);
                        executeCommand(commit);
                        // You must turn auto commit back on when done with the transaction.
                        SetAutoCommit setAutoCommit = new SetAutoCommit(connection, true);
                        executeCommand(setAutoCommit);
                }

                void rollbackTransaction() {
                        try {
                                connection.rollback();
                        } catch (SQLException e) {
                                logger.log(Level.SEVERE, "Error rolling back transaction", e);
                        }
                        try {
                                connection.setAutoCommit(true);
                        } catch (SQLException e) {
                                logger.log(Level.SEVERE, "Error restoring auto-commit", e);
                        }
                }

                void rollbackTransactionWithThrow() throws SQLException {
                        try {
                                connection.rollback();
                        } finally {
                                connection.setAutoCommit(true);
                        }
                }

                ResultSet executeQuery(Statement statement, String query) throws SQLException {
                        ExecuteQuery queryCommand = new ExecuteQuery(statement, query);
                        executeCommand(queryCommand);
                        return queryCommand.getResultSet();
                }

                ResultSet executeQuery(PreparedStatement statement) throws SQLException {
                        ExecutePreparedStatementQuery executePreparedStatementQuery = new ExecutePreparedStatementQuery(statement);
                        executeCommand(executePreparedStatementQuery);
                        return executePreparedStatementQuery.getResultSet();
                }

                void executeUpdate(Statement statement, String update) throws SQLException {
                        executeUpdate(statement, update, Statement.NO_GENERATED_KEYS);
                }

                void executeUpdate(Statement statement, String update, int generateKeys) throws SQLException {
                        ExecuteStatementUpdate executeStatementUpdate = new ExecuteStatementUpdate(statement, update);
                        executeCommand(executeStatementUpdate);
                }

                void executeUpdate(PreparedStatement statement) throws SQLException {
                        ExecutePreparedStatementUpdate executePreparedStatementUpdate = new ExecutePreparedStatementUpdate(statement);
                        executeCommand(executePreparedStatementUpdate);
                }

                void close() {
                        try {
                                connection.close();
                        } catch (SQLException ex) {
                                logger.log(Level.SEVERE, "Unable to close connection to case database", ex);
                        }
                }

                Connection getConnection() {
                        return this.connection;
                }
        }

        private final class SQLiteConnection extends CaseDbConnection {

                private static final int DATABASE_LOCKED_ERROR = 0; // This should be 6 according to documentation, but it has been observed to be 0.
                private static final int SQLITE_BUSY_ERROR = 5;

                SQLiteConnection(Connection conn) {
                        super(conn);
                }

                @Override
                void executeCommand(DbCommand command) throws SQLException {
                        while (true) {
                                try {
                                        command.execute(); // Perform the operation
                                        break;
                                } catch (SQLException ex) {
                                        if (ex.getErrorCode() == SQLITE_BUSY_ERROR || ex.getErrorCode() == DATABASE_LOCKED_ERROR) {
                                                try {
                                                        // We do not notify of error here, as this is not an
                                                        // error condition. It is likely a temporary busy or
                                                        // locked issue and we will retry.
                                                        Thread.sleep(SLEEP_LENGTH_IN_MILLISECONDS);
                                                } catch (InterruptedException exp) {
                                                        Logger.getLogger(SleuthkitCase.class.getName()).log(Level.WARNING, "Unexpectedly unable to wait for database.", exp);
                                                }
                                        } else {
                                                submitError(ErrorObserver.Context.DATABASE_READ_ERROR.getContextString(), ex.getMessage());
                                                throw ex;
                                        }
                                }
                        }
                }
        }

        private final class PostgreSQLConnection extends CaseDbConnection {

                private final String COMMUNICATION_ERROR = PSQLState.COMMUNICATION_ERROR.getState();
                private final String SYSTEM_ERROR = PSQLState.SYSTEM_ERROR.getState();
                private final String UNKNOWN_STATE = PSQLState.UNKNOWN_STATE.getState();
                private static final int MAX_RETRIES = 3;

                PostgreSQLConnection(Connection conn) {
                        super(conn);
                }

                @Override
                void executeUpdate(Statement statement, String update, int generateKeys) throws SQLException {
                        ExecuteStatementUpdateGenerateKeys executeStatementUpdateGenerateKeys = new ExecuteStatementUpdateGenerateKeys(statement, update, generateKeys);
                        executeCommand(executeStatementUpdateGenerateKeys);
                }

                @Override
                PreparedStatement prepareStatement(String sqlStatement, int generateKeys) throws SQLException {
                        PrepareStatementGenerateKeys prepareStatementGenerateKeys = new PrepareStatementGenerateKeys(this.getConnection(), sqlStatement, generateKeys);
                        executeCommand(prepareStatementGenerateKeys);
                        return prepareStatementGenerateKeys.getPreparedStatement();
                }

                @Override
                void executeCommand(DbCommand command) throws SQLException {
                        for (int retries = 0; retries < MAX_RETRIES; retries++) {
                                try {
                                        command.execute();
                                        break;
                                } catch (SQLException ex) {
                                        String sqlState = ((PSQLException) ex).getSQLState();
                                        if (sqlState.equals(COMMUNICATION_ERROR) || sqlState.equals(SYSTEM_ERROR) || sqlState.equals(UNKNOWN_STATE)) {
                                                try {
                                                        Thread.sleep(SLEEP_LENGTH_IN_MILLISECONDS);
                                                } catch (InterruptedException exp) {
                                                        Logger.getLogger(SleuthkitCase.class.getName()).log(Level.WARNING, "Unexpectedly unable to wait for database.", exp);
                                                }
                                        } else {
                                                submitError(ErrorObserver.Context.DATABASE_READ_ERROR.getContextString(), ex.getMessage());
                                                throw ex;
                                        }
                                }
                        }
                }
        }

        public static final class CaseDbTransaction {

                private final CaseDbConnection connection;

                private CaseDbTransaction(CaseDbConnection connection) throws TskCoreException {
                        this.connection = connection;
                        try {
                                this.connection.beginTransaction();
                        } catch (SQLException ex) {
                                throw new TskCoreException("Failed to create transaction on case database", ex);
                        }
                }

                private CaseDbConnection getConnection() {
                        return this.connection;
                }

                public void commit() throws TskCoreException {
                        try {
                                this.connection.commitTransaction();
                        } catch (SQLException ex) {
                                throw new TskCoreException("Failed to commit transaction on case database", ex);
                        } finally {
                                close();
                        }
                }

                public void rollback() throws TskCoreException {
                        try {
                                this.connection.rollbackTransactionWithThrow();
                        } catch (SQLException ex) {
                                throw new TskCoreException("Case database transaction rollback failed", ex);
                        } finally {
                                close();
                        }
                }

                void close() {
                        this.connection.close();
                }
        }

        public final class CaseDbQuery implements AutoCloseable {

                private ResultSet resultSet;
                private CaseDbConnection connection;

                private CaseDbQuery(String query) throws TskCoreException {
                        if (!query.regionMatches(true, 0, "SELECT", 0, "SELECT".length())) {
                                throw new TskCoreException("Unsupported query: Only SELECT queries are supported.");
                        }
                        try {
                                connection = connections.getConnection();
                        } catch (TskCoreException ex) {
                                throw new TskCoreException("Error getting connection for query: ", ex);
                        }

                        try {
                                SleuthkitCase.this.acquireSharedLock();
                                resultSet = connection.executeQuery(connection.createStatement(), query);
                        } catch (SQLException ex) {
                                SleuthkitCase.this.releaseSharedLock();
                                throw new TskCoreException("Error executing query: ", ex);
                        }
                }

                public ResultSet getResultSet() {
                        return resultSet;
                }

                @Override
                public void close() throws TskCoreException {
                        try {
                                if (resultSet != null) {
                                        final Statement statement = resultSet.getStatement();
                                        if (statement != null) {
                                                statement.close();
                                        }
                                        resultSet.close();
                                }
                                connection.close();
                        } catch (SQLException ex) {
                                throw new TskCoreException("Error closing query: ", ex);
                        } finally {
                                SleuthkitCase.this.releaseSharedLock();
                        }
                }
        }

        @Deprecated
        long getDataSourceObjectId(long objectId) {
                try {
                        CaseDbConnection connection = connections.getConnection();
                        try {
                                return getDataSourceObjectId(connection, objectId);
                        } finally {
                                connection.close();
                        }
                } catch (TskCoreException ex) {
                        logger.log(Level.SEVERE, "Error getting data source object id for a file", ex);
                        return 0;
                }
        }

        @Deprecated
        public long getLastObjectId() throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireExclusiveLock();
                ResultSet rs = null;
                try {
                        // SELECT MAX(obj_id) AS max_obj_id FROM tsk_objects
                        PreparedStatement statement = connection.getPreparedStatement(PREPARED_STATEMENT.SELECT_MAX_OBJECT_ID);
                        rs = connection.executeQuery(statement);
                        long id = -1;
                        if (rs.next()) {
                                id = rs.getLong("max_obj_id");
                        }
                        return id;
                } catch (SQLException e) {
                        throw new TskCoreException("Error getting last object id", e);
                } finally {
                        closeResultSet(rs);
                        connection.close();
                        releaseExclusiveLock();
                }
        }

        @Deprecated
        public List<FsContent> findFilesWhere(String sqlWhereClause) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT * FROM tsk_files WHERE " + sqlWhereClause); //NON-NLS
                        List<FsContent> results = new ArrayList<FsContent>();
                        List<AbstractFile> temp = resultSetToAbstractFiles(rs, connection);
                        for (AbstractFile f : temp) {
                                final TSK_DB_FILES_TYPE_ENUM type = f.getType();
                                if (type.equals(TskData.TSK_DB_FILES_TYPE_ENUM.FS)) {
                                        results.add((FsContent) f);
                                }
                        }
                        return results;
                } catch (SQLException e) {
                        throw new TskCoreException("SQLException thrown when calling 'SleuthkitCase.findFilesWhere().", e);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        @Deprecated
        public int getArtifactTypeID(String artifactTypeName) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT artifact_type_id FROM blackboard_artifact_types WHERE type_name = '" + artifactTypeName + "'"); //NON-NLS
                        int typeId = -1;
                        if (rs.next()) {
                                typeId = rs.getInt("artifact_type_id");
                        }
                        return typeId;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting artifact type id", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        @Deprecated
        public ArrayList<BlackboardArtifact.ARTIFACT_TYPE> getBlackboardArtifactTypes() throws TskCoreException {
                return new ArrayList<BlackboardArtifact.ARTIFACT_TYPE>(Arrays.asList(BlackboardArtifact.ARTIFACT_TYPE.values()));
        }

        @Deprecated
        public int addArtifactType(String artifactTypeName, String displayName) throws TskCoreException {
                try {
                        return addBlackboardArtifactType(artifactTypeName, displayName).getTypeID();
                } catch (TskDataException ex) {
                        throw new TskCoreException("Failed to add artifact type.", ex);
                }
        }

        @Deprecated
        public int addAttrType(String attrTypeString, String displayName) throws TskCoreException {
                try {
                        return addArtifactAttributeType(attrTypeString, TSK_BLACKBOARD_ATTRIBUTE_VALUE_TYPE.STRING, displayName).getTypeID();
                } catch (TskDataException ex) {
                        throw new TskCoreException("Couldn't add new attribute type");
                }
        }

        @Deprecated
        public int getAttrTypeID(String attrTypeName) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT attribute_type_id FROM blackboard_attribute_types WHERE type_name = '" + attrTypeName + "'"); //NON-NLS
                        int typeId = -1;
                        if (rs.next()) {
                                typeId = rs.getInt("attribute_type_id");
                        }
                        return typeId;
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting attribute type id", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        @Deprecated
        public String getAttrTypeString(int attrTypeID) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT type_name FROM blackboard_attribute_types WHERE attribute_type_id = " + attrTypeID); //NON-NLS
                        if (rs.next()) {
                                return rs.getString("type_name");
                        } else {
                                throw new TskCoreException("No type with that id");
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting or creating a attribute type name", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        @Deprecated
        public String getAttrTypeDisplayName(int attrTypeID) throws TskCoreException {
                CaseDbConnection connection = connections.getConnection();
                acquireSharedLock();
                Statement s = null;
                ResultSet rs = null;
                try {
                        s = connection.createStatement();
                        rs = connection.executeQuery(s, "SELECT display_name FROM blackboard_attribute_types WHERE attribute_type_id = " + attrTypeID); //NON-NLS
                        if (rs.next()) {
                                return rs.getString("display_name");
                        } else {
                                throw new TskCoreException("No type with that id");
                        }
                } catch (SQLException ex) {
                        throw new TskCoreException("Error getting or creating a attribute type name", ex);
                } finally {
                        closeResultSet(rs);
                        closeStatement(s);
                        connection.close();
                        releaseSharedLock();
                }
        }

        @Deprecated
        public ArrayList<BlackboardAttribute.ATTRIBUTE_TYPE> getBlackboardAttributeTypes() throws TskCoreException {
                return new ArrayList<BlackboardAttribute.ATTRIBUTE_TYPE>(Arrays.asList(BlackboardAttribute.ATTRIBUTE_TYPE.values()));
        }

        @Deprecated
        public ResultSet runQuery(String query) throws SQLException {
                CaseDbConnection connection;
                try {
                        connection = connections.getConnection();
                } catch (TskCoreException ex) {
                        throw new SQLException("Error getting connection for ad hoc query", ex);
                }
                acquireSharedLock();
                try {
                        return connection.executeQuery(connection.createStatement(), query);
                } finally {
                        //TODO unlock should be done in closeRunQuery()
                        //but currently not all code calls closeRunQuery - need to fix this
                        connection.close();
                        releaseSharedLock();
                }
        }

        @Deprecated
        public void closeRunQuery(ResultSet resultSet) throws SQLException {
                final Statement statement = resultSet.getStatement();
                resultSet.close();
                if (statement != null) {
                        statement.close();
                }
        }

        @Deprecated
        public LayoutFile addCarvedFile(String carvedFileName, long carvedFileSize, long containerId, List<TskFileRange> data) throws TskCoreException {
                CarvingResult.CarvedFile carvedFile = new CarvingResult.CarvedFile(carvedFileName, carvedFileSize, data);
                List<CarvingResult.CarvedFile> files = new ArrayList<CarvingResult.CarvedFile>();
                files.add(carvedFile);
                CarvingResult carvingResult;
                Content parent = getContentById(containerId);
                if (parent instanceof FileSystem
                                || parent instanceof Volume
                                || parent instanceof Image) {
                        carvingResult = new CarvingResult(parent, files);
                } else {
                        throw new TskCoreException(String.format("Parent (id =%d) is not an file system, volume or image", containerId));
                }
                return addCarvedFiles(carvingResult).get(0);
        }

        @Deprecated
        public List<LayoutFile> addCarvedFiles(List<CarvedFileContainer> filesToAdd) throws TskCoreException {
                List<CarvingResult.CarvedFile> carvedFiles = new ArrayList<CarvingResult.CarvedFile>();
                for (CarvedFileContainer container : filesToAdd) {
                        CarvingResult.CarvedFile carvedFile = new CarvingResult.CarvedFile(container.getName(), container.getSize(), container.getRanges());
                        carvedFiles.add(carvedFile);
                }
                CarvingResult carvingResult;
                Content parent = getContentById(filesToAdd.get(0).getId());
                if (parent instanceof FileSystem
                                || parent instanceof Volume
                                || parent instanceof Image) {
                        carvingResult = new CarvingResult(parent, carvedFiles);
                } else {
                        throw new TskCoreException(String.format("Parent (id =%d) is not an file system, volume or image", parent.getId()));
                }
                return addCarvedFiles(carvingResult);
        }

        @Deprecated
        public DerivedFile addDerivedFile(String fileName, String localPath,
                        long size, long ctime, long crtime, long atime, long mtime,
                        boolean isFile, AbstractFile parentFile,
                        String rederiveDetails, String toolName, String toolVersion, String otherDetails) throws TskCoreException {
                return addDerivedFile(fileName, localPath, size, ctime, crtime, atime, mtime,
                                isFile, parentFile, rederiveDetails, toolName, toolVersion,
                                otherDetails, TskData.EncodingType.NONE);
        }

        @Deprecated
        public LocalFile addLocalFile(String fileName, String localPath,
                        long size, long ctime, long crtime, long atime, long mtime,
                        boolean isFile,
                        AbstractFile parent, CaseDbTransaction transaction) throws TskCoreException {
                return addLocalFile(fileName, localPath, size, ctime, crtime, atime, mtime, isFile,
                                TskData.EncodingType.NONE, parent, transaction);
        }

        @Deprecated
        public LocalFile addLocalFile(String fileName, String localPath,
                        long size, long ctime, long crtime, long atime, long mtime,
                        boolean isFile,
                        AbstractFile parent) throws TskCoreException {
                return addLocalFile(fileName, localPath, size, ctime, crtime, atime, mtime,
                                isFile, TskData.EncodingType.NONE, parent);
        }

        @Deprecated
        public AddImageProcess makeAddImageProcess(String timezone, boolean addUnallocSpace, boolean noFatFsOrphans) {
                return this.caseHandle.initAddImageProcess(timezone, addUnallocSpace, noFatFsOrphans, "");
        }

}