AbstractDatabase.h [plain text]
#ifndef AbstractDatabase_h
#define AbstractDatabase_h
#if ENABLE(SQL_DATABASE)
#include "PlatformString.h"
#include "SQLiteDatabase.h"
#include <wtf/Forward.h>
#include <wtf/ThreadSafeRefCounted.h>
#if !LOG_DISABLED || !ERROR_DISABLED
#include "SecurityOrigin.h"
#endif
namespace WebCore {
class DatabaseAuthorizer;
class DatabaseContext;
class ScriptExecutionContext;
class SecurityOrigin;
typedef int ExceptionCode;
class AbstractDatabase : public ThreadSafeRefCounted<AbstractDatabase> {
public:
static bool isAvailable();
static void setIsAvailable(bool available);
virtual ~AbstractDatabase();
virtual String version() const;
bool opened() const { return m_opened; }
bool isNew() const { return m_new; }
bool isSyncDatabase() const { return m_isSyncDatabase; }
virtual ScriptExecutionContext* scriptExecutionContext() const;
virtual SecurityOrigin* securityOrigin() const;
virtual String stringIdentifier() const;
virtual String displayName() const;
virtual unsigned long estimatedSize() const;
virtual String fileName() const;
SQLiteDatabase& sqliteDatabase() { return m_sqliteDatabase; }
unsigned long long maximumSize() const;
void incrementalVacuumIfNeeded();
void interrupt();
bool isInterrupted();
void disableAuthorizer();
void enableAuthorizer();
void setAuthorizerReadOnly();
void setAuthorizerPermissions(int permissions);
bool lastActionChangedDatabase();
bool lastActionWasInsert();
void resetDeletes();
bool hadDeletes();
void resetAuthorizer();
virtual void markAsDeletedAndClose() = 0;
virtual void closeImmediately() = 0;
DatabaseContext* databaseContext() const { return m_databaseContext; }
protected:
friend class ChangeVersionWrapper;
friend class SQLStatement;
friend class SQLStatementSync;
friend class SQLTransactionSync;
friend class SQLTransaction;
enum DatabaseType {
AsyncDatabase,
SyncDatabase
};
AbstractDatabase(ScriptExecutionContext*, const String& name, const String& expectedVersion,
const String& displayName, unsigned long estimatedSize, DatabaseType);
void closeDatabase();
virtual bool performOpenAndVerify(bool shouldSetVersionInNewDatabase, ExceptionCode&, String& errorMessage);
bool getVersionFromDatabase(String& version, bool shouldCacheVersion = true);
bool setVersionInDatabase(const String& version, bool shouldCacheVersion = true);
void setExpectedVersion(const String&);
const String& expectedVersion() const { return m_expectedVersion; }
String getCachedVersion()const;
void setCachedVersion(const String&);
bool getActualVersionForTransaction(String& version);
void logErrorMessage(const String& message);
void reportOpenDatabaseResult(int errorSite, int webSqlErrorCode, int sqliteErrorCode);
void reportChangeVersionResult(int errorSite, int webSqlErrorCode, int sqliteErrorCode);
void reportStartTransactionResult(int errorSite, int webSqlErrorCode, int sqliteErrorCode);
void reportCommitTransactionResult(int errorSite, int webSqlErrorCode, int sqliteErrorCode);
void reportExecuteStatementResult(int errorSite, int webSqlErrorCode, int sqliteErrorCode);
void reportVacuumDatabaseResult(int sqliteErrorCode);
static const char* databaseInfoTableName();
RefPtr<SecurityOrigin> m_contextThreadSecurityOrigin;
RefPtr<ScriptExecutionContext> m_scriptExecutionContext;
DatabaseContext* m_databaseContext;
String m_name;
String m_expectedVersion;
String m_displayName;
unsigned long m_estimatedSize;
String m_filename;
#if !LOG_DISABLED || !ERROR_DISABLED
String databaseDebugName() const { return m_contextThreadSecurityOrigin->toString() + "::" + m_name; }
#endif
private:
int m_guid;
bool m_opened;
bool m_new;
const bool m_isSyncDatabase;
SQLiteDatabase m_sqliteDatabase;
RefPtr<DatabaseAuthorizer> m_databaseAuthorizer;
};
}
#endif // ENABLE(SQL_DATABASE)
#endif // AbstractDatabase_h