Latest Tutorials| Questions and Answers|Ask Questions?|Site Map



Home Answers Viewqa Development-process groupby implement in java
Login         

View Questions and Answers by Category

Advertisements


 
Have Programming Question? Ask it here!
 
 
 


muralanagaraju
groupby implement in java
0 Answer(s)      a year and 9 months ago
Posted in : Development process


**import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.util.Arrays;
import java.util.Hashtable;
import java.util.Vector;
public class FileReading {
    /**
     * @param args
     */
    ///public  Hashtable<String, Object> isExistRecord(String oldCurrentLine,String unique,Vector<Integer> vec){
        public  Hashtable<String,Object >  groupByDataWriteToFile(String oldCurrentLine,String unique,Vector<Integer> vec,String delimeter) throws IOException{
        Hashtable<String,Object> resultHash = new Hashtable<String,Object>();
        BufferedReader br = null;
        BufferedWriter bufferFileWriter  = null;
        boolean isexist = false;
        String path = "D:\\groupBy.txt"; 
        int countR=0;
        try {
             String writepath = "D:\\groupBy.txt";     
             File file = new File(writepath);
             FileWriter fileWriter = new FileWriter(file,true); 
             String sCurrentLine;
             bufferFileWriter = new BufferedWriter(fileWriter);
             br = new BufferedReader(new FileReader(path));
             if(unique !=null && unique.equals("first")){
                ////System.out.println("Enter First Record --->"+oldCurrentLine );
                bufferFileWriter.write(oldCurrentLine);
                bufferFileWriter.newLine();
                bufferFileWriter.flush();
                isexist = true;
                resultHash.put("isexist",true);
                resultHash.put("currentRow",oldCurrentLine);
                return resultHash;
             }
            else{
            while (((sCurrentLine = br.readLine()) != null)) {
                ////System.out.println("sCurrentLine ----->"+sCurrentLine);


                    String arry[] = sCurrentLine.split("\\"+delimeter);
                    String oldarry[]  =oldCurrentLine.split("\\"+delimeter);
                    boolean groupBycolumnsCheckFlag = checkGroupByColumns(vec,arry,oldarry);
                    ////System.out.println("groupBycolumnsCheckFlag --->"+groupBycolumnsCheckFlag);
                    if(groupBycolumnsCheckFlag){
                        ////System.out.println("sCurrentLine record  -->"+sCurrentLine);
                        String cnt= arry[(arry.length-1)];
                        countR =Integer.parseInt(cnt);
                        countR = countR+1;
                        arry[(arry.length-1)] =countR+"";
                        ////System.out.println(oldCurrentLine+"-->old is  -->"+ arry[(arry.length-1)]);
                        //String finalStr = oldarry[0]+","+oldarry[1]+","+oldarry[2]+","+oldarry[3]+","+oldarry[4]+","+arry[(arry.length-1)];
                        String finalStr = UpdateSameRowWithCount(vec,oldarry,arry,delimeter);
                        //System.out.println("finalString record  -->"+finalStr);
                        bufferFileWriter.write(finalStr);
                        bufferFileWriter.newLine();
                        bufferFileWriter.flush();
                        isexist = true;
                        resultHash.put("isexist",true);
                        resultHash.put("currentRow",sCurrentLine);
                        closeConnections(br,bufferFileWriter);
                        /*br = null;
                        bufferFileWriter =null; */
                        temFileCreate(new BufferedReader(new FileReader("D:\\groupBy.txt")),oldCurrentLine,countR,vec,delimeter);
                        resultHash.put("isexist",true);
                        resultHash.put("currentRow",sCurrentLine);
                        return resultHash;
                }
                else if(!sCurrentLine.equals(oldCurrentLine)){
                    resultHash.put("isexist",isexist);
                    resultHash.put("currentRow",sCurrentLine);
                }
            }
        }
        bufferFileWriter.write(oldCurrentLine);
        bufferFileWriter.newLine();
        bufferFileWriter.flush();
        resultHash.put("isexist",true);
        resultHash.put("currentRow",oldCurrentLine);
        return resultHash;
        } catch (IOException e) {
            e.printStackTrace();
            return resultHash;
        } finally {
            closeConnections(br,bufferFileWriter);
        }
    }
    public boolean checkGroupByColumns(Vector<Integer> vec,String[] currentRowArray,String[] checkRowArray){
        boolean checkFlag = true;
        for(int index = 0;index<vec.size();index++ ){
            if(!currentRowArray[index].toString().trim().equals(checkRowArray[index].toString().trim())){
                checkFlag = false;
                return checkFlag;
            }
        }
        return checkFlag;

    }
    public String UpdateSameRowWithCount(Vector<Integer> vec,String[] oldarry,String[] arry,String delimeter ){
        String updatedString = "";
        /*for(int index = 0;index<vec.size();index++ ){
            if(index ==0 || index== (vec.size()-1))
                updatedString += oldarry[index];
            else
                updatedString += oldarry[vec.get(index)]+",";

        }*/
        Vector<String> veci =new Vector<String>(Arrays.asList(oldarry)); 
        //System.out.println("Vector ------>"+veci);
        for(int index = 0;index<oldarry.length-1;index++ ){
            /*if(index ==0 || index== (vec.size()-1))
                updatedString += oldarry[index];
            else*/
                updatedString += oldarry[index]+delimeter;

        }
        if(arry!=null && arry.length>0)
            updatedString += arry[(arry.length-1)];
    //  //System.out.println("Prepare updatedString Count String --->"+updatedString);
        return updatedString;
    }
    public  void temFileCreate(BufferedReader br,String currentLine,int count,Vector<Integer> vec,String delimeter)throws IOException
    {
        BufferedWriter  bufferFileWritertemp1=null;
        bufferFileWritertemp1=new BufferedWriter(new FileWriter("D:\\groupBytemp.txt"));
        String[] arry=currentLine.split("\\"+delimeter);
        String currenline1="";
        String[] oldarry=null;
        while((currenline1=br.readLine())!=null)
        {
            //System.out.println("While loop start  --->"+currenline1);
            oldarry=currenline1.split("\\"+delimeter);
            boolean groupBycolumnsCheckFlag = checkGroupByColumns(vec,arry,oldarry);
            //if((arry[0].equals(oldarry[0]))&&(arry[1].equals(oldarry[1]))&&(arry[2].equals(oldarry[2]))&&(arry[3].equals(oldarry[3]))&&(arry[4].equals(oldarry[4]))&&(count==Integer.parseInt(oldarry[oldarry.length-1])))
            if(groupBycolumnsCheckFlag&&(count==Integer.parseInt(oldarry[oldarry.length-1])))
            {
                //System.out.println("duplicate replace --->"+currenline1);
                bufferFileWritertemp1.write(currenline1);
                bufferFileWritertemp1.write("\n");
            }
            //else if(!((arry[0].equals(oldarry[0]))&&(arry[1].equals(oldarry[1]))&&(arry[2].equals(oldarry[2]))&&(arry[3].equals(oldarry[3]))&&(arry[4].equals(oldarry[4]))))
            else if(!groupBycolumnsCheckFlag)
            {
                //System.out.println("Unique --->"+currenline1);
                bufferFileWritertemp1.write(currenline1);
                bufferFileWritertemp1.write("\n");
            }
        }

        closeConnections(br,bufferFileWritertemp1);
        /*br = null;
        bufferFileWritertemp1 = null;*/
        File newfile1 =new File("D:\\groupBy.txt");
        if(newfile1.delete()){
            ////System.out.println(newfile1.getName() + " is deleted!");
        }else{
            ////System.out.println(newfile1.getName() +"Delete operation is failed.");
        }
        File oldfile =new File("D:\\groupBytemp.txt");
        File newfile =new File("D:\\groupBy.txt");
        if(oldfile.renameTo(newfile)){
            ////System.out.println("success -->");
        }
        else{
            ////System.out.println("failure -->");
        }
    }
/*  public  Hashtable<String,Object >  groupByDataWriteToFile(String sCurrentLine,String unique,Vector<Integer> vec) throws IOException{
        Hashtable<String,Object > resultHash =isExistRecord(sCurrentLine,unique,vec);
        return resultHash;
    }
*/  
    public void prepareGroupBy(Vector<Integer> vec,String delimeter) {
        BufferedReader br = null;
        BufferedWriter bufferFileWriter  = null;
        try {
            String sCurrentLine;
            br = new BufferedReader(new FileReader("D:\\completeprimarydups.txt"));
            int count =0;
            while ((sCurrentLine = br.readLine()) != null) {
                ////System.out.println("Enter into first phase");
                if(count ==0){
                    groupByDataWriteToFile(sCurrentLine+delimeter+"1","first",vec ,delimeter);
                }
                else {
                    //System.out.println("exixsting  Record--->"+sCurrentLine);
                    Hashtable<String,Object> resultHash = null;
                    if(sCurrentLine !=null&&sCurrentLine.toString().trim().length()>0)
                    {
                        resultHash =    groupByDataWriteToFile(sCurrentLine+delimeter+"1","same",vec,delimeter);
                    }
                //  //System.out.println("resultHash ===>"+resultHash);
             if(resultHash!=null && resultHash.size()>0) {
                 System.out.println("resultHash"+resultHash);
                 Boolean status = (Boolean) resultHash.get("isexist");
                 if(!status) {
                     if(sCurrentLine !=null&&sCurrentLine.toString().trim().length()>0)
                            groupByDataWriteToFile(sCurrentLine+delimeter+"1","unique",vec,delimeter );
                 }
             }
            }
                count++;
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
                closeConnections(br,bufferFileWriter);
        }   
    }
public void closeConnections(BufferedReader br,BufferedWriter bw)
    {
        try {
            if(br!=null)
            {
                try {
                br.close();
                br = null;
                } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
                }
            }
            if(bw!=null)
            {
                bw.close();
                bw = null;
            }

            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
    }   
public static void main(String[] args)throws Exception {
        // TODO Auto-generated method stub
        Vector<Integer> vec = new Vector<Integer>();
        vec.add(0);
        vec.add(1);
        vec.add(2);
        vec.add(3);
        vec.add(4);
        FileReading fileReaderObj = new FileReading();
        String delimeter=",";
        fileReaderObj.prepareGroupBy(vec,delimeter);
        System.out.println("---Suceessfull Completed----");
    }
}**

Advertisement
View Answers

Related Tutorials/Questions & Answers:
groupby implement in java
groupby implement in java  **import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.util.Arrays
groupby implement in java
groupby implement in java  **import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.File; import java.io.FileReader; import java.io.FileWriter; import java.io.IOException; import java.util.Arrays
Advertisements
groupby functionality in java
groupby functionality in java  import java.io.BufferedReader; import... java.util.ArrayList; class Groupby{ BufferedReader readexistingfile = null...){} } public static void main(String arg[]){ Groupby group = new Groupby
java: implement a class queue
java: implement a class queue  Implement a class Queue which supports the following operations: boolean isEmpty() Returns true if the queue is empty, and false otherwise. int peak() Returns the value at the front of a non
Java code to implement MULTIPATH INHERITANCE
Java code to implement MULTIPATH INHERITANCE  HI, I am new to java programming. I want to implement multipath inheritance in one java program... Please write code for above example to implement both
Java code to implement MULTIPATH INHERITANCE
Java code to implement MULTIPATH INHERITANCE  Hi, I am new to java .so please write code for this inheritance example... Student | ----------- | | Test Sports
How to implement FTP using java
How to implement FTP using java  Hi, I am a B.tech student and I want to implement FTP using Java to transfer files and exchange files between FTP client and FTP server. Could anyone help me for How to implement FTP using java
What is an efficient way to implement a singleton pattern in Java?
What is an efficient way to implement a singleton pattern in Java?  What is an efficient way to implement a singleton pattern in Java
Java question to implement polymorphism - Java Beginners
Java question to implement polymorphism  I have a question that i need to answer:- Using the principle of polymorphism provide implementation for the calculateFees() method for each Online Fax Subscription type
How to implement openId java web based application?
How to implement openId java web based application?  In my web application i want to implement the OpenId just like stackoverflow.com have to login.... Please tell me how to implement it in java web application in details
Java Programming Implement a virtual print queue
Java Programming Implement a virtual print queue  Implement... records: q,3,10 is a q type record which indicates that a print job, # 3, shall.... You must implement the queue insert and remove methods as described in the text
How to implement a superclass Person? - Java Beginners
How to implement a superclass Person?  How to implement a superclass Person. Make two classes, Student and Lecturer, that inherit from Person... to implement the class..and how to write the toString method? please help me...  
How to implement this superclass Person - Java Beginners
How to implement this superclass Person  how to Implement a superclass Person which it need to Make two classes, Student and Instructor, that inherit from Person. A person has a name and a year of birth. A student has a major
Implement the Queue in Java
Implement the Queue in Java       In this section, you will learn how to implement the queue. A queue holds a collection of data or elements and follows the FIFO ( First In First
Implement Java clients calling Web Services
Implement Java clients calling Web... the enterprise components Next    Implement Java clients calling Web Services Generating a Java client proxy and a sample
The implement keyword
The implement keyword       In java programming language, the keyword implement specifies...) into a java class. A class implementing an interface must either implement all
Implement push
Implement push  Hi.. How do you implement push on a flex applications? give me answer with example so i clearly understand Thanks  Ans: push implement on a flex applications using BlazeDS Server
Implement push
Implement push  hi....... just tell me about How do you implement push with flex data services? give me answer with example Thanks  Ans: Using BlazeDS Server and Live Cycle Data Services
Implement transaction serializability
Implement transaction serializability  I need to implement transaction serializability in Java using semaphores/monnitors. What is the code to do
implement microsoft office
implement microsoft office   how implement microsoft office in my java swing project ,or when microsoft office is not install then file open in defualt text editar.please send me source code
implement sale purchaes
implement sale purchaes  i want to implement a code in advance java with connectivity .. i have a table in database in which i have some stack of sms if customer puchases and enter value in text box the amount will be deduct
Implement the Serializable Interface
Implement the Serializable Interface  hii How many methods do u implement if implement the Serializable Interface?   hiii... to implement
Implement an interface in a JSP
Implement an interface in a JSP  Can we implement an interface in a JSP?   
Where to implement spring - Spring
Where to implement spring   Hi, Where we implement spring framework in j2ee appplication. I mean which layer .Thanks
Implement Drag and drop
Implement Drag and drop  Hi...... Please give the answer with example How do you implement drag and drop on components that do not support ondrag and ondrop? Thanks in advance   Ans: The example
Program to implement array of Objects.
Program to implement array of Objects.  Create a class it has following data members:- -name -account id -balance initialize the data members through constructors & define a print function & also define a function
Implement This Skeleton Code
Implement This Skeleton Code  package jp.co.worksap.global; import java.util.NoSuchElementException; /** * The Queue class represents an immutable first-in-first-out (FIFO) queue of objects. * @param <E> */ public class
Implement The Skeleton Code
Implement The Skeleton Code  package jp.co.worksap.global; import java.util.NoSuchElementException; /** The Queue class represents an immutable first-in-first-out (FIFO) queue of objects. @param <E> */ public class
Implement array of objects
Implement array of objects  import java.io.*; import java.util.*; public class dataa { DataInputStream in=new DataInputStream(System.in); int i; int a[i]=int acid[5]; String name1[i]=new String[5
program to implement array of objects
program to implement array of objects  import java.io.*; import java.util.*; public class dataa { DataInputStream in=new DataInputStream(System.in); int i; int a[i]=int acid[5]; String name1[i]=new String[5
Can an Interface implement another Interface?
Can an Interface implement another Interface?   Hi, Can an Interface implement another Interface? Thanks
 

 

 

DMCA.com