| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2010 Google Inc. All rights reserved. | 2 * Copyright (C) 2010 Google Inc. All rights reserved. |
| 3 * | 3 * |
| 4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
| 5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
| 6 * are met: | 6 * are met: |
| 7 * | 7 * |
| 8 * 1. Redistributions of source code must retain the above copyright | 8 * 1. Redistributions of source code must retain the above copyright |
| 9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
| 10 * 2. Redistributions in binary form must reproduce the above copyright | 10 * 2. Redistributions in binary form must reproduce the above copyright |
| (...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 62 void reportTransactionFailed(ExecuteSQLCallback* requestCallback, SQLError* erro
r) | 62 void reportTransactionFailed(ExecuteSQLCallback* requestCallback, SQLError* erro
r) |
| 63 { | 63 { |
| 64 RefPtr<TypeBuilder::Database::Error> errorObject = TypeBuilder::Database::Er
ror::create() | 64 RefPtr<TypeBuilder::Database::Error> errorObject = TypeBuilder::Database::Er
ror::create() |
| 65 .setMessage(error->message()) | 65 .setMessage(error->message()) |
| 66 .setCode(error->code()); | 66 .setCode(error->code()); |
| 67 requestCallback->sendSuccess(nullptr, nullptr, errorObject.release()); | 67 requestCallback->sendSuccess(nullptr, nullptr, errorObject.release()); |
| 68 } | 68 } |
| 69 | 69 |
| 70 class StatementCallback FINAL : public SQLStatementCallback { | 70 class StatementCallback FINAL : public SQLStatementCallback { |
| 71 public: | 71 public: |
| 72 static PassOwnPtrWillBeRawPtr<StatementCallback> create(PassRefPtrWillBeRawP
tr<ExecuteSQLCallback> requestCallback) | 72 static StatementCallback* create(PassRefPtrWillBeRawPtr<ExecuteSQLCallback>
requestCallback) |
| 73 { | 73 { |
| 74 return adoptPtrWillBeNoop(new StatementCallback(requestCallback)); | 74 return new StatementCallback(requestCallback); |
| 75 } | 75 } |
| 76 | 76 |
| 77 virtual ~StatementCallback() { } | 77 virtual ~StatementCallback() { } |
| 78 | 78 |
| 79 virtual void trace(Visitor* visitor) | 79 virtual void trace(Visitor* visitor) |
| 80 { | 80 { |
| 81 visitor->trace(m_requestCallback); | 81 visitor->trace(m_requestCallback); |
| 82 SQLStatementCallback::trace(visitor); | 82 SQLStatementCallback::trace(visitor); |
| 83 } | 83 } |
| 84 | 84 |
| (...skipping 21 matching lines...) Expand all Loading... |
| 106 } | 106 } |
| 107 | 107 |
| 108 private: | 108 private: |
| 109 StatementCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCallback
) | 109 StatementCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCallback
) |
| 110 : m_requestCallback(requestCallback) { } | 110 : m_requestCallback(requestCallback) { } |
| 111 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 111 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
| 112 }; | 112 }; |
| 113 | 113 |
| 114 class StatementErrorCallback FINAL : public SQLStatementErrorCallback { | 114 class StatementErrorCallback FINAL : public SQLStatementErrorCallback { |
| 115 public: | 115 public: |
| 116 static PassOwnPtrWillBeRawPtr<StatementErrorCallback> create(PassRefPtrWillB
eRawPtr<ExecuteSQLCallback> requestCallback) | 116 static StatementErrorCallback* create(PassRefPtrWillBeRawPtr<ExecuteSQLCallb
ack> requestCallback) |
| 117 { | 117 { |
| 118 return adoptPtrWillBeNoop(new StatementErrorCallback(requestCallback)); | 118 return new StatementErrorCallback(requestCallback); |
| 119 } | 119 } |
| 120 | 120 |
| 121 virtual ~StatementErrorCallback() { } | 121 virtual ~StatementErrorCallback() { } |
| 122 | 122 |
| 123 virtual void trace(Visitor* visitor) OVERRIDE | 123 virtual void trace(Visitor* visitor) OVERRIDE |
| 124 { | 124 { |
| 125 visitor->trace(m_requestCallback); | 125 visitor->trace(m_requestCallback); |
| 126 SQLStatementErrorCallback::trace(visitor); | 126 SQLStatementErrorCallback::trace(visitor); |
| 127 } | 127 } |
| 128 | 128 |
| 129 virtual bool handleEvent(SQLTransaction*, SQLError* error) OVERRIDE | 129 virtual bool handleEvent(SQLTransaction*, SQLError* error) OVERRIDE |
| 130 { | 130 { |
| 131 reportTransactionFailed(m_requestCallback.get(), error); | 131 reportTransactionFailed(m_requestCallback.get(), error); |
| 132 return true; | 132 return true; |
| 133 } | 133 } |
| 134 | 134 |
| 135 private: | 135 private: |
| 136 StatementErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCal
lback) | 136 StatementErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCal
lback) |
| 137 : m_requestCallback(requestCallback) { } | 137 : m_requestCallback(requestCallback) { } |
| 138 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 138 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
| 139 }; | 139 }; |
| 140 | 140 |
| 141 class TransactionCallback FINAL : public SQLTransactionCallback { | 141 class TransactionCallback FINAL : public SQLTransactionCallback { |
| 142 public: | 142 public: |
| 143 static PassOwnPtrWillBeRawPtr<TransactionCallback> create(const String& sqlS
tatement, PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestCallback) | 143 static TransactionCallback* create(const String& sqlStatement, PassRefPtrWil
lBeRawPtr<ExecuteSQLCallback> requestCallback) |
| 144 { | 144 { |
| 145 return adoptPtrWillBeNoop(new TransactionCallback(sqlStatement, requestC
allback)); | 145 return new TransactionCallback(sqlStatement, requestCallback); |
| 146 } | 146 } |
| 147 | 147 |
| 148 virtual ~TransactionCallback() { } | 148 virtual ~TransactionCallback() { } |
| 149 | 149 |
| 150 virtual void trace(Visitor* visitor) OVERRIDE | 150 virtual void trace(Visitor* visitor) OVERRIDE |
| 151 { | 151 { |
| 152 visitor->trace(m_requestCallback); | 152 visitor->trace(m_requestCallback); |
| 153 SQLTransactionCallback::trace(visitor); | 153 SQLTransactionCallback::trace(visitor); |
| 154 } | 154 } |
| 155 | 155 |
| 156 virtual bool handleEvent(SQLTransaction* transaction) OVERRIDE | 156 virtual bool handleEvent(SQLTransaction* transaction) OVERRIDE |
| 157 { | 157 { |
| 158 if (!m_requestCallback->isActive()) | 158 if (!m_requestCallback->isActive()) |
| 159 return true; | 159 return true; |
| 160 | 160 |
| 161 Vector<SQLValue> sqlValues; | 161 Vector<SQLValue> sqlValues; |
| 162 OwnPtrWillBeRawPtr<SQLStatementCallback> callback(StatementCallback::cre
ate(m_requestCallback.get())); | 162 SQLStatementCallback* callback = StatementCallback::create(m_requestCall
back.get()); |
| 163 OwnPtrWillBeRawPtr<SQLStatementErrorCallback> errorCallback(StatementErr
orCallback::create(m_requestCallback.get())); | 163 SQLStatementErrorCallback* errorCallback = StatementErrorCallback::creat
e(m_requestCallback.get()); |
| 164 transaction->executeSQL(m_sqlStatement, sqlValues, callback.release(), e
rrorCallback.release(), IGNORE_EXCEPTION); | 164 transaction->executeSQL(m_sqlStatement, sqlValues, callback, errorCallba
ck, IGNORE_EXCEPTION); |
| 165 return true; | 165 return true; |
| 166 } | 166 } |
| 167 private: | 167 private: |
| 168 TransactionCallback(const String& sqlStatement, PassRefPtrWillBeRawPtr<Execu
teSQLCallback> requestCallback) | 168 TransactionCallback(const String& sqlStatement, PassRefPtrWillBeRawPtr<Execu
teSQLCallback> requestCallback) |
| 169 : m_sqlStatement(sqlStatement) | 169 : m_sqlStatement(sqlStatement) |
| 170 , m_requestCallback(requestCallback) { } | 170 , m_requestCallback(requestCallback) { } |
| 171 String m_sqlStatement; | 171 String m_sqlStatement; |
| 172 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 172 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
| 173 }; | 173 }; |
| 174 | 174 |
| 175 class TransactionErrorCallback FINAL : public SQLTransactionErrorCallback { | 175 class TransactionErrorCallback FINAL : public SQLTransactionErrorCallback { |
| 176 public: | 176 public: |
| 177 static PassOwnPtrWillBeRawPtr<TransactionErrorCallback> create(PassRefPtrWil
lBeRawPtr<ExecuteSQLCallback> requestCallback) | 177 static TransactionErrorCallback* create(PassRefPtrWillBeRawPtr<ExecuteSQLCal
lback> requestCallback) |
| 178 { | 178 { |
| 179 return adoptPtrWillBeNoop(new TransactionErrorCallback(requestCallback))
; | 179 return new TransactionErrorCallback(requestCallback); |
| 180 } | 180 } |
| 181 | 181 |
| 182 virtual ~TransactionErrorCallback() { } | 182 virtual ~TransactionErrorCallback() { } |
| 183 | 183 |
| 184 virtual void trace(Visitor* visitor) OVERRIDE | 184 virtual void trace(Visitor* visitor) OVERRIDE |
| 185 { | 185 { |
| 186 visitor->trace(m_requestCallback); | 186 visitor->trace(m_requestCallback); |
| 187 SQLTransactionErrorCallback::trace(visitor); | 187 SQLTransactionErrorCallback::trace(visitor); |
| 188 } | 188 } |
| 189 | 189 |
| 190 virtual bool handleEvent(SQLError* error) OVERRIDE | 190 virtual bool handleEvent(SQLError* error) OVERRIDE |
| 191 { | 191 { |
| 192 reportTransactionFailed(m_requestCallback.get(), error); | 192 reportTransactionFailed(m_requestCallback.get(), error); |
| 193 return true; | 193 return true; |
| 194 } | 194 } |
| 195 private: | 195 private: |
| 196 TransactionErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestC
allback) | 196 TransactionErrorCallback(PassRefPtrWillBeRawPtr<ExecuteSQLCallback> requestC
allback) |
| 197 : m_requestCallback(requestCallback) { } | 197 : m_requestCallback(requestCallback) { } |
| 198 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; | 198 RefPtrWillBeMember<ExecuteSQLCallback> m_requestCallback; |
| 199 }; | 199 }; |
| 200 | 200 |
| 201 class TransactionSuccessCallback FINAL : public VoidCallback { | 201 class TransactionSuccessCallback FINAL : public VoidCallback { |
| 202 public: | 202 public: |
| 203 static PassOwnPtrWillBeRawPtr<TransactionSuccessCallback> create() | 203 static TransactionSuccessCallback* create() |
| 204 { | 204 { |
| 205 return adoptPtrWillBeNoop(new TransactionSuccessCallback()); | 205 return new TransactionSuccessCallback(); |
| 206 } | 206 } |
| 207 | 207 |
| 208 virtual ~TransactionSuccessCallback() { } | 208 virtual ~TransactionSuccessCallback() { } |
| 209 | 209 |
| 210 virtual void handleEvent() OVERRIDE { } | 210 virtual void handleEvent() OVERRIDE { } |
| 211 | 211 |
| 212 private: | 212 private: |
| 213 TransactionSuccessCallback() { } | 213 TransactionSuccessCallback() { } |
| 214 }; | 214 }; |
| 215 | 215 |
| (...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 307 requestCallback->sendFailure("Database agent is not enabled"); | 307 requestCallback->sendFailure("Database agent is not enabled"); |
| 308 return; | 308 return; |
| 309 } | 309 } |
| 310 | 310 |
| 311 Database* database = databaseForId(databaseId); | 311 Database* database = databaseForId(databaseId); |
| 312 if (!database) { | 312 if (!database) { |
| 313 requestCallback->sendFailure("Database not found"); | 313 requestCallback->sendFailure("Database not found"); |
| 314 return; | 314 return; |
| 315 } | 315 } |
| 316 | 316 |
| 317 OwnPtrWillBeRawPtr<SQLTransactionCallback> callback(TransactionCallback::cre
ate(query, requestCallback.get())); | 317 SQLTransactionCallback* callback = TransactionCallback::create(query, reques
tCallback.get()); |
| 318 OwnPtrWillBeRawPtr<SQLTransactionErrorCallback> errorCallback(TransactionErr
orCallback::create(requestCallback.get())); | 318 SQLTransactionErrorCallback* errorCallback = TransactionErrorCallback::creat
e(requestCallback.get()); |
| 319 OwnPtrWillBeRawPtr<VoidCallback> successCallback(TransactionSuccessCallback:
:create()); | 319 VoidCallback* successCallback = TransactionSuccessCallback::create(); |
| 320 database->transaction(callback.release(), errorCallback.release(), successCa
llback.release()); | 320 database->transaction(callback, errorCallback, successCallback); |
| 321 } | 321 } |
| 322 | 322 |
| 323 InspectorDatabaseResource* InspectorDatabaseAgent::findByFileName(const String&
fileName) | 323 InspectorDatabaseResource* InspectorDatabaseAgent::findByFileName(const String&
fileName) |
| 324 { | 324 { |
| 325 for (DatabaseResourcesHeapMap::iterator it = m_resources.begin(); it != m_re
sources.end(); ++it) { | 325 for (DatabaseResourcesHeapMap::iterator it = m_resources.begin(); it != m_re
sources.end(); ++it) { |
| 326 if (it->value->database()->fileName() == fileName) | 326 if (it->value->database()->fileName() == fileName) |
| 327 return it->value.get(); | 327 return it->value.get(); |
| 328 } | 328 } |
| 329 return 0; | 329 return 0; |
| 330 } | 330 } |
| 331 | 331 |
| 332 Database* InspectorDatabaseAgent::databaseForId(const String& databaseId) | 332 Database* InspectorDatabaseAgent::databaseForId(const String& databaseId) |
| 333 { | 333 { |
| 334 DatabaseResourcesHeapMap::iterator it = m_resources.find(databaseId); | 334 DatabaseResourcesHeapMap::iterator it = m_resources.find(databaseId); |
| 335 if (it == m_resources.end()) | 335 if (it == m_resources.end()) |
| 336 return 0; | 336 return 0; |
| 337 return it->value->database(); | 337 return it->value->database(); |
| 338 } | 338 } |
| 339 | 339 |
| 340 void InspectorDatabaseAgent::trace(Visitor* visitor) | 340 void InspectorDatabaseAgent::trace(Visitor* visitor) |
| 341 { | 341 { |
| 342 #if ENABLE(OILPAN) | 342 #if ENABLE(OILPAN) |
| 343 visitor->trace(m_resources); | 343 visitor->trace(m_resources); |
| 344 #endif | 344 #endif |
| 345 InspectorBaseAgent::trace(visitor); | 345 InspectorBaseAgent::trace(visitor); |
| 346 } | 346 } |
| 347 | 347 |
| 348 } // namespace blink | 348 } // namespace blink |
| OLD | NEW |