X-Git-Url: https://code.wpia.club/?p=gigi.git;a=blobdiff_plain;f=src%2Forg%2Fcacert%2Fgigi%2FdbObjects%2FDomain.java;h=6b0e82830d07a2f9e0c4121a0910c3217d7674aa;hp=7e35225f4d99d409cee53e9aec64544c8563df9a;hb=b47144d6f3bf6b6eb1ec477de9d2af38256f074f;hpb=a7aea81ff9eebb35aef0f91dfa8b5e3c797568f8 diff --git a/src/org/cacert/gigi/dbObjects/Domain.java b/src/org/cacert/gigi/dbObjects/Domain.java index 7e35225f..6b0e8283 100644 --- a/src/org/cacert/gigi/dbObjects/Domain.java +++ b/src/org/cacert/gigi/dbObjects/Domain.java @@ -15,53 +15,10 @@ import org.cacert.gigi.GigiApiException; import org.cacert.gigi.database.DatabaseConnection; import org.cacert.gigi.database.GigiPreparedStatement; import org.cacert.gigi.database.GigiResultSet; -import org.cacert.gigi.dbObjects.DomainPingConfiguration.PingType; import org.cacert.gigi.util.PublicSuffixes; public class Domain implements IdCachable, Verifyable { - public class DomainPingExecution { - - private String state; - - private String type; - - private String info; - - private String result; - - private DomainPingConfiguration config; - - public DomainPingExecution(GigiResultSet rs) { - state = rs.getString(1); - type = rs.getString(2); - info = rs.getString(3); - result = rs.getString(4); - config = DomainPingConfiguration.getById(rs.getInt(5)); - } - - public String getState() { - return state; - } - - public String getType() { - return type; - } - - public String getInfo() { - return info; - } - - public String getResult() { - return result; - } - - public DomainPingConfiguration getConfig() { - return config; - } - - } - private User owner; private String suffix; @@ -81,7 +38,7 @@ public class Domain implements IdCachable, Verifyable { } private Domain(int id) { - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT memid, domain FROM `domains` WHERE id=? AND deleted IS NULL"); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT `memid`, `domain` FROM `domains` WHERE `id`=? AND `deleted` IS NULL"); ps.setInt(1, id); GigiResultSet rs = ps.executeQuery(); @@ -95,10 +52,12 @@ public class Domain implements IdCachable, Verifyable { } public Domain(User owner, String suffix) throws GigiApiException { - checkCertifyableDomain(suffix, owner.isInGroup(Group.CODESIGNING)); - this.owner = owner; - this.suffix = suffix; - + synchronized (Domain.class) { + checkCertifyableDomain(suffix, owner.isInGroup(Group.CODESIGNING)); + this.owner = owner; + this.suffix = suffix; + insert(); + } } public static void checkCertifyableDomain(String s, boolean hasPunycodeRight) throws GigiApiException { @@ -156,7 +115,7 @@ public class Domain implements IdCachable, Verifyable { } private static void checkInsert(String suffix) throws GigiApiException { - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT 1 FROM `domains` WHERE (domain=? OR (CONCAT('.', domain)=RIGHT(?,LENGTH(domain)+1) OR RIGHT(domain,LENGTH(?)+1)=CONCAT('.',?))) AND deleted IS NULL"); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT 1 FROM `domains` WHERE (`domain`=? OR (CONCAT('.', `domain`)=RIGHT(?,LENGTH(`domain`)+1) OR RIGHT(`domain`,LENGTH(?)+1)=CONCAT('.',?))) AND `deleted` IS NULL"); ps.setString(1, suffix); ps.setString(2, suffix); ps.setString(3, suffix); @@ -169,26 +128,24 @@ public class Domain implements IdCachable, Verifyable { } } - public void insert() throws GigiApiException { - synchronized (Domain.class) { - if (id != 0) { - throw new GigiApiException("already inserted."); - } - checkInsert(suffix); - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("INSERT INTO `domains` SET memid=?, domain=?"); - ps.setInt(1, owner.getId()); - ps.setString(2, suffix); - ps.execute(); - id = ps.lastInsertId(); - myCache.put(this); + private void insert() throws GigiApiException { + if (id != 0) { + throw new GigiApiException("already inserted."); } + checkInsert(suffix); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("INSERT INTO `domains` SET memid=?, domain=?"); + ps.setInt(1, owner.getId()); + ps.setString(2, suffix); + ps.execute(); + id = ps.lastInsertId(); + myCache.put(this); } public void delete() throws GigiApiException { if (id == 0) { throw new GigiApiException("not inserted."); } - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("UPDATE `domains` SET deleted=CURRENT_TIMESTAMP WHERE id=?"); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("UPDATE `domains` SET `deleted`=CURRENT_TIMESTAMP WHERE `id`=?"); ps.setInt(1, id); ps.execute(); } @@ -225,8 +182,8 @@ public class Domain implements IdCachable, Verifyable { return Collections.unmodifiableList(configs); } - public void addPing(PingType type, String config) throws GigiApiException { - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("INSERT INTO pingconfig SET domainid=?, type=?, info=?"); + public void addPing(DomainPingType type, String config) throws GigiApiException { + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("INSERT INTO `pingconfig` SET `domainid`=?, `type`=?::`pingType`, `info`=?"); ps.setInt(1, id); ps.setString(2, type.toString().toLowerCase()); ps.setString(3, config); @@ -235,21 +192,21 @@ public class Domain implements IdCachable, Verifyable { } public synchronized void verify(String hash) throws GigiApiException { - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("UPDATE domainPinglog SET state='success' WHERE challenge=? AND configId IN (SELECT id FROM pingconfig WHERE domainId=?)"); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("UPDATE `domainPinglog` SET `state`='success' WHERE `challenge`=? AND `configId` IN (SELECT `id` FROM `pingconfig` WHERE `domainid`=?)"); ps.setString(1, hash); ps.setInt(2, id); ps.executeUpdate(); } public boolean isVerified() { - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT 1 FROM domainPinglog INNER JOIN pingconfig ON pingconfig.id=domainPinglog.configId WHERE domainid=? AND state='success'"); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT 1 FROM `domainPinglog` INNER JOIN `pingconfig` ON `pingconfig`.`id`=`domainPinglog`.`configId` WHERE `domainid`=? AND `state`='success'"); ps.setInt(1, id); GigiResultSet rs = ps.executeQuery(); return rs.next(); } public DomainPingExecution[] getPings() throws GigiApiException { - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT state, type, info, result, configId FROM domainPinglog INNER JOIN pingconfig ON pingconfig.id=domainPinglog.configid WHERE pingconfig.domainid=? ORDER BY `when` DESC;"); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepareScrollable("SELECT `state`, `type`, `info`, `result`, `configId` FROM `domainPinglog` INNER JOIN `pingconfig` ON `pingconfig`.`id`=`domainPinglog`.`configId` WHERE `pingconfig`.`domainid`=? ORDER BY `when` DESC;"); ps.setInt(1, id); GigiResultSet rs = ps.executeQuery(); rs.last(); @@ -273,10 +230,9 @@ public class Domain implements IdCachable, Verifyable { } public static int searchUserIdByDomain(String domain) { - GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT memid FROM domains WHERE domain = ?"); + GigiPreparedStatement ps = DatabaseConnection.getInstance().prepare("SELECT `memid` FROM `domains` WHERE `domain` = ?"); ps.setString(1, domain); GigiResultSet res = ps.executeQuery(); - res.beforeFirst(); if (res.next()) { return res.getInt(1); } else {