Method main

src/test/java/test_JXTp.java:26–98

(String[] args)

    private static String K_aes = "8975924566f6e252";

    public static void main(String[] args) {
        //Step 1 prepare the parameters
        //the number of attributes which aren't the join attribute in the table.
        int key_colnum = 9;
        //the number join attributes in the table.
        int join_column = 1;
        int record_num = (int)Math.pow(2, 16);//the number of records of the table (65536 lines)
        String condition = "";//used to choose different tables from dataset, e.g., "_14".

        System.out.println("--------------------- JXT+ -----------------------");
        //Step 2 begin to set up
        Setup_JXTp table_1 = new Setup_JXTp(1, key_colnum, join_column, record_num, condition);
        table_1.construct();
        Map<BigInteger, ArrayList<byte[]>> tset = table_1.getTset();

        Setup_JXTp table_2 = new Setup_JXTp(2, key_colnum, join_column, record_num, condition);
        table_2.construct();
        tset.putAll(table_2.getTset());
        //Step 3 begin to search
        for (int v = 0; v < 20; v++) {
            String keyword1 = "keyword0" + "table1_keyword_" + v + "_0";
            String keyword2 = "keyword0" + "table2_keyword_" + v + "_0";
            System.out.println("--------- JXT+ search(table_keyword_" + v + "_0) ---------");
            String join_attr1 = "join-attr0";
            String join_attr2 = "join-attr0";
            long search_all = 0;
            for (int x = 0; x < 1000; x++) {
                long search_start = System.nanoTime();
                Server_JXTp serverMJXT = new Server_JXTp(tset, table_1.getF(),
                        table_1.getCset(), table_2.getF(), table_2.getCset());
                //Step 3.1 compute the stag
                BigInteger stag1 = new BigInteger(Hash.Get_SHA_256((K_token + keyword1 + join_attr1 + 1).getBytes(StandardCharsets.UTF_8)));
                int cnt1 = serverMJXT.tset_table1_cnt(stag1);
                byte[][] join_token1 = new byte[cnt1][];
                byte[][] join_token2 = new byte[cnt1][];
                byte[] w = Hash.Get_SHA_256((K_w + keyword1 + 0).getBytes(StandardCharsets.UTF_8));
                byte[] y = Hash.Get_SHA_256((K_w + keyword2 + 0).getBytes(StandardCharsets.UTF_8));
                byte[] join_hash1 = Hash.Get_SHA_256((K_h + join_attr1).getBytes(StandardCharsets.UTF_8));
                byte[] join_hash2 = Hash.Get_SHA_256((K_h + join_attr2).getBytes(StandardCharsets.UTF_8));
                //Step 3.2 compute the joinTokens
                for (int i = 0; i < cnt1; i++) {
                    byte[] w_cnt = Hash.Get_SHA_256((K_w + keyword1 + (i + 1)).getBytes(StandardCharsets.UTF_8));
                    join_token1[i] = tool.Xor(tool.Xor(w, w_cnt), join_hash1);
                    join_token2[i] = tool.Xor(tool.Xor(y, w_cnt), join_hash2);
                }
                //Step 3.3 the server returns the satisfying results
                ArrayList<ArrayList<byte[]>> res = serverMJXT.search(join_token1, join_token2);
                byte[] k_dec1 = Hash.Get_SHA_256((K_aes + keyword1).getBytes());
                byte[] k_dec2 = Hash.Get_SHA_256((K_aes + keyword2).getBytes());
                //Step 3.4 decrypt the encrypted identifiers
                for (int i = 0; i < res.size(); i++) {
                    if (i % 2 == 0){
                        ArrayList<byte[]> res_i = res.get(i);
                        for (int j = 0; j < res_i.size(); j++) {
                            AESUtil.decrypt(k_dec1, res_i.get(j));
                        }
                    }else {
                        ArrayList<byte[]> res_i = res.get(i);