X-Git-Url: https://code.wpia.club/?a=blobdiff_plain;f=src%2Forg%2Fcacert%2Fgigi%2FdbObjects%2FCertificateOwner.java;h=a66229fe6bdefa90a8d6ef9df07d1f9341e87d11;hb=8eaf45ee6a71969eff3e04b40e4435e0dd380824;hp=daff8bcb787866d631c83793f3794876c3beccf9;hpb=d65cca2357ffab506900a0fff0ee41caae0e742d;p=gigi.git diff --git a/src/org/cacert/gigi/dbObjects/CertificateOwner.java b/src/org/cacert/gigi/dbObjects/CertificateOwner.java index daff8bcb..a66229fe 100644 --- a/src/org/cacert/gigi/dbObjects/CertificateOwner.java +++ b/src/org/cacert/gigi/dbObjects/CertificateOwner.java @@ -8,6 +8,7 @@ import java.io.Serializable; import java.util.LinkedList; import java.util.List; +import org.cacert.gigi.GigiApiException; import org.cacert.gigi.database.GigiPreparedStatement; import org.cacert.gigi.database.GigiResultSet; @@ -36,25 +37,33 @@ public abstract class CertificateOwner implements IdCachable, Serializable { } public static synchronized CertificateOwner getById(int id) { - CertificateOwner u = myCache.get(id); - if (u == null) { - try (GigiPreparedStatement ps = new GigiPreparedStatement("SELECT *, `users`.`id` AS uid, `organisations`.`id` AS oid FROM `certOwners` LEFT JOIN `users` ON `users`.`id`=`certOwners`.`id` LEFT JOIN `organisations` ON `organisations`.`id` = `certOwners`.`id` WHERE `certOwners`.`id`=? AND `deleted` is null")) { - ps.setInt(1, id); - try (GigiResultSet rs = ps.executeQuery()) { - if ( !rs.next()) { - return null; - } - if (rs.getString("uid") != null) { - myCache.put(u = new User(rs)); - } else if (rs.getString("oid") != null) { - myCache.put(u = new Organisation(rs)); - } else { - System.err.print("Malformed cert owner: " + id); - } - } + CertificateOwner cached = myCache.get(id); + if (cached != null) { + return cached; + } + + try (GigiPreparedStatement psU = new GigiPreparedStatement("SELECT *, `users`.`id` AS uid FROM `certOwners` INNER JOIN `users` ON `users`.`id`=`certOwners`.`id` WHERE `certOwners`.`id`=? AND `deleted` is null")) { + psU.setInt(1, id); + GigiResultSet rsU = psU.executeQuery(); + if (rsU.next()) { + return myCache.put(new User(rsU)); } + } catch (GigiApiException e) { + throw new Error(e); } - return u; + + try (GigiPreparedStatement psO = new GigiPreparedStatement("SELECT *, `organisations`.`id` AS oid FROM `certOwners` INNER JOIN `organisations` ON `organisations`.`id`=`certOwners`.`id` WHERE `certOwners`.`id`=? AND `deleted` is null")) { + psO.setInt(1, id); + GigiResultSet rsO = psO.executeQuery(); + if (rsO.next()) { + return myCache.put(new Organisation(rsO)); + } + } catch (GigiApiException e) { + throw new Error(e); + } + + System.err.println("Malformed cert owner: " + id); + return null; } public Domain[] getDomains() { @@ -124,7 +133,7 @@ public abstract class CertificateOwner implements IdCachable, Serializable { public static CertificateOwner getByEnabledSerial(String serial) { try (GigiPreparedStatement prep = new GigiPreparedStatement("SELECT `memid` FROM `certs` INNER JOIN `logincerts` ON `logincerts`.`id`=`certs`.`id` WHERE serial=? AND `revoked` is NULL")) { - prep.setString(1, serial.toLowerCase()); + prep.setString(1, serial); GigiResultSet res = prep.executeQuery(); if (res.next()) { return getById(res.getInt(1));