first commit

Author: yashbrid03

.classpath

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>
+	<classpathentry kind="src" path="src"/>
+	<classpathentry kind="lib" path="C:/Program Files/mysql-connector-java-5.1.49/mysql-connector-java-5.1.49.jar"/>
+	<classpathentry kind="lib" path="C:/Program Files/mysql-connector-java-5.1.49/mysql-connector-java-5.1.49-bin.jar"/>
+	<classpathentry kind="output" path="bin"/>
+</classpath>

.project

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectDescription>
+	<name>todolist</name>
+	<comment></comment>
+	<projects>
+	</projects>
+	<buildSpec>
+		<buildCommand>
+			<name>org.eclipse.jdt.core.javabuilder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
+	</buildSpec>
+	<natures>
+		<nature>org.eclipse.jdt.core.javanature</nature>
+	</natures>
+</projectDescription>

.settings/org.eclipse.jdt.core.prefs

@@ -0,0 +1,12 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.debug.lineNumber=generate
+org.eclipse.jdt.core.compiler.debug.localVariable=generate
+org.eclipse.jdt.core.compiler.debug.sourceFile=generate
+org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
+org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8

OUTPUT.PNG

@@ -0,0 +1,44 @@
+/*
+  Copyright (c) 2013, 2014, Oracle and/or its affiliates. All rights reserved.
+
+  The MySQL Connector/J is licensed under the terms of the GPLv2
+  <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most MySQL Connectors.
+  There are special exceptions to the terms and conditions of the GPLv2 as it is applied to
+  this software, see the FOSS License Exception
+  <http://www.mysql.com/about/legal/licensing/foss-exception.html>.
+
+  This program is free software; you can redistribute it and/or modify it under the terms
+  of the GNU General Public License as published by the Free Software Foundation; version 2
+  of the License.
+
+  This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+  See the GNU General Public License for more details.
+
+  You should have received a copy of the GNU General Public License along with this
+  program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth
+  Floor, Boston, MA 02110-1301  USA
+
+ */
+
+package com.mysql.fabric;
+
+/**
+ * Indicates an exceptional condition while communicating with a Fabric server.
+ */
+public class FabricCommunicationException extends Exception {
+
+    private static final long serialVersionUID = 1L;
+
+    public FabricCommunicationException(Throwable cause) {
+        super(cause);
+    }
+
+    public FabricCommunicationException(String message) {
+        super(message);
+    }
+
+    public FabricCommunicationException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

bin/todolist/DB.class

@@ -0,0 +1,129 @@
+/*
+  Copyright (c) 2013, 2016, Oracle and/or its affiliates. All rights reserved.
+
+  The MySQL Connector/J is licensed under the terms of the GPLv2
+  <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most MySQL Connectors.
+  There are special exceptions to the terms and conditions of the GPLv2 as it is applied to
+  this software, see the FOSS License Exception
+  <http://www.mysql.com/about/legal/licensing/foss-exception.html>.
+
+  This program is free software; you can redistribute it and/or modify it under the terms
+  of the GNU General Public License as published by the Free Software Foundation; version 2
+  of the License.
+
+  This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+  See the GNU General Public License for more details.
+
+  You should have received a copy of the GNU General Public License along with this
+  program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth
+  Floor, Boston, MA 02110-1301  USA
+
+ */
+
+package com.mysql.fabric;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+
+import com.mysql.fabric.proto.xmlrpc.XmlRpcClient;
+
+public class FabricConnection {
+    private XmlRpcClient client;
+
+    // internal caches
+    private Map<String, ShardMapping> shardMappingsByTableName = new HashMap<String, ShardMapping>();
+    private Map<String, ServerGroup> serverGroupsByName = new HashMap<String, ServerGroup>();
+    private long shardMappingsExpiration;
+    private int shardMappingsTtl;
+    private long serverGroupsExpiration;
+    private int serverGroupsTtl;
+
+    public FabricConnection(String url, String username, String password) throws FabricCommunicationException {
+        this.client = new XmlRpcClient(url, username, password);
+        refreshState();
+    }
+
+    /**
+     * @param urls
+     * @param username
+     * @param password
+     * @throws FabricCommunicationException
+     */
+    public FabricConnection(Set<String> urls, String username, String password) throws FabricCommunicationException {
+        throw new UnsupportedOperationException("Multiple connections not supported.");
+    }
+
+    public String getInstanceUuid() {
+        return null;
+    }
+
+    public int getVersion() {
+        return 0;
+    }
+
+    /**
+     * @return version of state data
+     */
+    public int refreshState() throws FabricCommunicationException {
+        FabricStateResponse<Set<ServerGroup>> serverGroups = this.client.getServerGroups();
+        FabricStateResponse<Set<ShardMapping>> shardMappings = this.client.getShardMappings();
+
+        this.serverGroupsExpiration = serverGroups.getExpireTimeMillis();
+        this.serverGroupsTtl = serverGroups.getTtl();
+        for (ServerGroup g : serverGroups.getData()) {
+            this.serverGroupsByName.put(g.getName(), g);
+        }
+
+        this.shardMappingsExpiration = shardMappings.getExpireTimeMillis();
+        this.shardMappingsTtl = shardMappings.getTtl();
+        for (ShardMapping m : shardMappings.getData()) {
+            // a shard mapping may be associated with more than one table
+            for (ShardTable t : m.getShardTables()) {
+                this.shardMappingsByTableName.put(t.getDatabase() + "." + t.getTable(), m);
+            }
+        }
+
+        return 0;
+    }
+
+    public int refreshStatePassive() {
+        try {
+            return refreshState();
+        } catch (FabricCommunicationException e) {
+            // Fabric node is down but we can operate on previous setup. Just reset the TTL timers.
+            this.serverGroupsExpiration = System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(this.serverGroupsTtl);
+            this.shardMappingsExpiration = System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(this.shardMappingsTtl);
+        }
+
+        return 0;
+    }
+
+    public ServerGroup getServerGroup(String serverGroupName) {
+        if (isStateExpired()) {
+            refreshStatePassive();
+        }
+        return this.serverGroupsByName.get(serverGroupName);
+    }
+
+    public ShardMapping getShardMapping(String database, String table) {
+        if (isStateExpired()) {
+            refreshStatePassive();
+        }
+        return this.shardMappingsByTableName.get(database + "." + table);
+    }
+
+    public boolean isStateExpired() {
+        return System.currentTimeMillis() > this.shardMappingsExpiration || System.currentTimeMillis() > this.serverGroupsExpiration;
+    }
+
+    public Set<String> getFabricHosts() {
+        return null;
+    }
+
+    public XmlRpcClient getClient() {
+        return this.client;
+    }
+}

bin/todolist/todo$1.class

@@ -0,0 +1,59 @@
+/*
+  Copyright (c) 2013, 2016, Oracle and/or its affiliates. All rights reserved.
+
+  The MySQL Connector/J is licensed under the terms of the GPLv2
+  <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most MySQL Connectors.
+  There are special exceptions to the terms and conditions of the GPLv2 as it is applied to
+  this software, see the FOSS License Exception
+  <http://www.mysql.com/about/legal/licensing/foss-exception.html>.
+
+  This program is free software; you can redistribute it and/or modify it under the terms
+  of the GNU General Public License as published by the Free Software Foundation; version 2
+  of the License.
+
+  This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+  See the GNU General Public License for more details.
+
+  You should have received a copy of the GNU General Public License along with this
+  program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth
+  Floor, Boston, MA 02110-1301  USA
+
+ */
+
+package com.mysql.fabric;
+
+import java.util.concurrent.TimeUnit;
+
+public class FabricStateResponse<T> {
+    private T data;
+    private int secsTtl;
+    private long expireTimeMillis;
+
+    public FabricStateResponse(T data, int secsTtl) {
+        this.data = data;
+        this.secsTtl = secsTtl;
+        this.expireTimeMillis = System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(secsTtl);
+    }
+
+    public FabricStateResponse(T data, int secsTtl, long presetExpireTimeMillis) {
+        this.data = data;
+        this.secsTtl = secsTtl;
+        this.expireTimeMillis = presetExpireTimeMillis;
+    }
+
+    public T getData() {
+        return this.data;
+    }
+
+    public int getTtl() {
+        return this.secsTtl;
+    }
+
+    /**
+     * The expiration time of this data. Should be compared to {@link System.currentTimeMillis()}.
+     */
+    public long getExpireTimeMillis() {
+        return this.expireTimeMillis;
+    }
+}

bin/todolist/todo$2.class

@@ -0,0 +1,83 @@
+/*
+  Copyright (c) 2013, 2017, Oracle and/or its affiliates. All rights reserved.
+
+  The MySQL Connector/J is licensed under the terms of the GPLv2
+  <http://www.gnu.org/licenses/old-licenses/gpl-2.0.html>, like most MySQL Connectors.
+  There are special exceptions to the terms and conditions of the GPLv2 as it is applied to
+  this software, see the FOSS License Exception
+  <http://www.mysql.com/about/legal/licensing/foss-exception.html>.
+
+  This program is free software; you can redistribute it and/or modify it under the terms
+  of the GNU General Public License as published by the Free Software Foundation; version 2
+  of the License.
+
+  This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+  without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+  See the GNU General Public License for more details.
+
+  You should have received a copy of the GNU General Public License along with this
+  program; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth
+  Floor, Boston, MA 02110-1301  USA
+
+ */
+
+package com.mysql.fabric;
+
+import java.math.BigInteger;
+import java.security.MessageDigest;
+import java.util.Comparator;
+import java.util.Set;
+import java.util.TreeSet;
+
+/**
+ * A shard mapping with ranges defined by hashing key values. Lookups work essentially
+ * the same as in {@link RangeShardMapping} but strings are compared as opposed to ints.
+ */
+public class HashShardMapping extends ShardMapping {
+    private static class ReverseShardIndexSorter implements Comparator<ShardIndex> {
+        public int compare(ShardIndex i1, ShardIndex i2) {
+            return i2.getBound().compareTo(i1.getBound());
+        }
+
+        // singleton instance
+        public static final ReverseShardIndexSorter instance = new ReverseShardIndexSorter();
+    }
+
+    private static final MessageDigest md5Hasher;
+
+    static {
+        try {
+            md5Hasher = MessageDigest.getInstance("MD5");
+        } catch (java.security.NoSuchAlgorithmException ex) {
+            throw new ExceptionInInitializerError(ex);
+        }
+    }
+
+    public HashShardMapping(int mappingId, ShardingType shardingType, String globalGroupName, Set<ShardTable> shardTables, Set<ShardIndex> shardIndices) {
+        super(mappingId, shardingType, globalGroupName, shardTables, new TreeSet<ShardIndex>(ReverseShardIndexSorter.instance));
+        this.shardIndices.addAll(shardIndices);
+    }
+
+    @Override
+    protected ShardIndex getShardIndexForKey(String stringKey) {
+        String hashedKey;
+        synchronized (md5Hasher) {
+            hashedKey = new BigInteger(/* unsigned/positive */1, md5Hasher.digest(stringKey.getBytes())).toString(16).toUpperCase();
+        }
+
+        // pad out to 32 digits
+        for (int i = 0; i < (32 - hashedKey.length()); ++i) {
+            hashedKey = "0" + hashedKey;
+        }
+
+        for (ShardIndex i : this.shardIndices) {
+            if (i.getBound().compareTo(hashedKey) <= 0) {
+                return i;
+            }
+        }
+
+        // default to the first (highest) bound,
+        // implementing wrapping
+        return this.shardIndices.iterator().next();
+    }
+}