Line data Source code
1 : // Copyright (C) 2017 The Android Open Source Project 2 : // 3 : // Licensed under the Apache License, Version 2.0 (the "License"); 4 : // you may not use this file except in compliance with the License. 5 : // You may obtain a copy of the License at 6 : // 7 : // http://www.apache.org/licenses/LICENSE-2.0 8 : // 9 : // Unless required by applicable law or agreed to in writing, software 10 : // distributed under the License is distributed on an "AS IS" BASIS, 11 : // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 : // See the License for the specific language governing permissions and 13 : // limitations under the License. 14 : 15 : package com.google.gerrit.server.schema; 16 : 17 : import com.google.gerrit.exceptions.DuplicateKeyException; 18 : import com.google.gerrit.exceptions.StorageException; 19 : import com.google.gerrit.server.config.GerritServerConfig; 20 : import com.google.gerrit.server.config.SitePaths; 21 : import com.google.gerrit.server.config.ThreadSettingsConfig; 22 : import com.google.inject.Inject; 23 : import com.google.inject.Singleton; 24 : import java.sql.SQLException; 25 : import java.sql.Statement; 26 : import org.eclipse.jgit.lib.Config; 27 : 28 : @Singleton 29 : public class MariaDBAccountPatchReviewStore extends JdbcAccountPatchReviewStore { 30 : 31 : @Inject 32 : MariaDBAccountPatchReviewStore( 33 : @GerritServerConfig Config cfg, 34 : SitePaths sitePaths, 35 : ThreadSettingsConfig threadSettingsConfig) { 36 0 : super(cfg, sitePaths, threadSettingsConfig); 37 0 : } 38 : 39 : @Override 40 : public StorageException convertError(String op, SQLException err) { 41 0 : switch (err.getErrorCode()) { 42 : case 1022: // ER_DUP_KEY 43 : case 1062: // ER_DUP_ENTRY 44 : case 1169: // ER_DUP_UNIQUE; 45 0 : return new DuplicateKeyException("ACCOUNT_PATCH_REVIEWS", err); 46 : 47 : default: 48 0 : if (err.getCause() == null && err.getNextException() != null) { 49 0 : err.initCause(err.getNextException()); 50 : } 51 0 : return new StorageException(op + " failure on ACCOUNT_PATCH_REVIEWS", err); 52 : } 53 : } 54 : 55 : @Override 56 : protected void doCreateTable(Statement stmt) throws SQLException { 57 0 : stmt.executeUpdate( 58 : "CREATE TABLE IF NOT EXISTS account_patch_reviews (" 59 : + "account_id INTEGER DEFAULT 0 NOT NULL, " 60 : + "change_id INTEGER DEFAULT 0 NOT NULL, " 61 : + "patch_set_id INTEGER DEFAULT 0 NOT NULL, " 62 : + "file_name VARCHAR(255) DEFAULT '' NOT NULL, " 63 : + "CONSTRAINT primary_key_account_patch_reviews " 64 : + "PRIMARY KEY (change_id, patch_set_id, account_id, file_name)" 65 : + ")"); 66 0 : } 67 : }