sendQuery.java

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;

class sendQuery implements Runnable 
{   /**********************/
     int sockPort = 7005 ;
    /*********************/
    sendQuery()
    {
     // Red args if any
    }   
    @Override
    public void run()
    {
        try 
        {
            //Creating a client socket to send query requests
            Socket socketConnection = new Socket("localhost", sockPort) ;
            
            // Files for input queries and responses
            String inputfile = "./Input/" + Thread.currentThread().getName() + "_input.txt" ;
            String outputfile = "./Output/" +Thread.currentThread().getName() + "_output.txt" ;

            //-----Initialising the Input & ouput file-streams and buffers-------
            OutputStreamWriter outputStream = new OutputStreamWriter(socketConnection
                                                                     .getOutputStream());
            BufferedWriter bufferedOutput = new BufferedWriter(outputStream);
            InputStreamReader inputStream = new InputStreamReader(socketConnection
                                                                  .getInputStream());
            BufferedReader bufferedInput = new BufferedReader(inputStream);
            PrintWriter printWriter = new PrintWriter(bufferedOutput,true);
            File queries = new File(inputfile); 
            File output = new File(outputfile); 
            FileWriter filewriter = new FileWriter(output);
            Scanner queryScanner = new Scanner(queries);
            String query = "";
            //--------------------------------------------------------------------

            // Read input queries and write to the output stream
            while(queryScanner.hasNextLine())
            {
                query = queryScanner.nextLine();
                printWriter.println(query);
            }

            //System.out.println("Query sent from " + Thread.currentThread().getName());

            // Get query responses from the input end of the socket of client
            String result;
            while( (result = bufferedInput.readLine()) != null)
            {
                filewriter.write(result + "\n");
            }    
            // close the buffers and socket
            filewriter.close();
            queryScanner.close();
            printWriter.close();
            socketConnection.close();
        } 
        catch (IOException e1)
        {
            e1.printStackTrace();
        }   
    }
}