Method main

src/test/java/M_JXTp.java:26–106

(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 values{5, 6, 7, 8, 9} for our dataset
        //the number join attributes in the table.
        int join_column = 1;//the values{5, 4, 3, 2, 1} for our dataset
        int record_num = (int)Math.pow(2, 16);//the number of records of the table (65536 lines)
        int table_num = 3;//the number of the queried tables
        String condition = "";//used to choose different tables from dataset, e.g., "_4".
        String[] keyword = new String[table_num];
        String[] join_attr = new String[table_num];
        //Step 2 begin to set up
        System.out.println("------------- MJXT+ ---------------");
        System.out.println("---------- MJXT+ setup ------------");
        long setup_start = System.nanoTime();
        Setup_JXTp[] table = new Setup_JXTp[table_num];
        Map<BigInteger, ArrayList<byte[]>> tset = new LinkedHashMap<>();
        for (int i = 0; i < table_num; i++) {
            table[i] = new Setup_JXTp(i + 1, key_colnum, join_column, record_num, condition);
            table[i].construct();
            tset.putAll(table[i].getTset());
        }
        long setup_end = System.nanoTime();
        System.out.println("JXT+ setup time : " + (setup_end - setup_start)/Math.pow(10, 6) + " ms");

        //Step 3 begin to search
        for (int i = 0; i < table_num; i++) {//set the queried attribute-value pairs and join attributes
            keyword[i] = "keyword0" + "table" + (i + 1) + "_keyword_0_0";
            join_attr[i] = "join-attr0";
        }

        long search_all = 0;
        for (int x = 0; x < 1000; x++) {//run 1000 times
            long search_start = System.nanoTime();
            Server_MJXTp serverMJXTp = new Server_MJXTp(tset, table);
            //Step 3.1 compute the stags
            BigInteger stag1 = new BigInteger(Hash.Get_SHA_256((K_token + keyword[0] + join_attr[0] + 1).getBytes(StandardCharsets.UTF_8)));
            int cnt1 = serverMJXTp.tset_table1_cnt(stag1);
            //Step 3.2 compute the joinTokens
            ArrayList<byte[][]> join_tokens = new ArrayList<>();
            byte[][] w_cnt = new byte[cnt1][];
            for (int i = 0; i < cnt1; i++) {
                w_cnt[i] = Hash.Get_SHA_256((K_w + keyword[0] + (i + 1)).getBytes(StandardCharsets.UTF_8));
            }
            for (int i = 0; i < table_num; i++) {
                byte[] w = Hash.Get_SHA_256((K_w + keyword[i] + 0).getBytes(StandardCharsets.UTF_8));
                byte[] join_hash = Hash.Get_SHA_256((K_h + join_attr[i]).getBytes(StandardCharsets.UTF_8));
                byte[][] join_token = new byte[cnt1][];
                for (int j = 0; j < cnt1; j++) {
                    join_token[j] = tool.Xor(tool.Xor(w_cnt[j], w), join_hash);
                }
                join_tokens.add(join_token);
            }
            //Step 3.3 the server returns the satisfying results
            ArrayList<ArrayList<byte[]>> res = serverMJXTp.search(join_tokens);
            //Step 3.4 decrypt the encrypted identifiers
            byte[][] k_dec = new byte[table_num][];
            for (int i = 0; i < table_num; i++) {