package Packg;

import javax.swing.*;
import java.sql.*;
import java.awt.*;
import java.awt.event.*;
import java.util.*;

public class Add_Record extends JFrame implements ActionListener
{

private Container container;
private int counter=0;
private JButton button[];
private JTextField tf[];
private Data dat;
private Vector v;
private String cn[];
private int ct[];
private String sou,tn;
private Connection connection;
public Add_Record(String so,String tn1, String cn1[],int ct1[])
{
    ct=ct1;
    sou=so;
    tn=tn1;
    cn=cn1;
    container=getContentPane();
    formGUI();
    setTitle("Add Record");
    setBounds(50,50,350,350);
    setVisible(true);
     setResizable(false);
}
public void formGUI()
{
    JLabel label[]=new JLabel[cn.length];
    tf=new JTextField[cn.length];

    JPanel panel_field=new JPanel(new GridLayout(cn.length,2));

    for(int i=0;i<label.length;i++)
    {
        label[i]=new JLabel();
        label[i].setText(cn[i]);
        tf[i]=new JTextField(20);
        tf[i].setText("");
        panel_field.add(label[i]);
        panel_field.add(tf[i]);
    }

    button=new JButton[1];

    JPanel panel=new JPanel(new GridLayout(1,4));

    for(int i=0;i<button.length;i++)
    {
        button[i]=new JButton();
        panel.add(button[i]);
        button[i].addActionListener(this);
    }
    button[0].setText("Add");

    container.add(panel_field,BorderLayout.NORTH);
    container.add(panel,BorderLayout.SOUTH);
    empty();
}


public void actionPerformed(ActionEvent e)
{
    if(e.getSource()==button[0])
    {
        add();
        empty();
    }


}
public void empty()
{
    for(int i=0;i<tf.length;i++)
    {
        tf[i].setText("");
    }

}
public void add()
{
    try
    {
        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
        String source="jdbc:odbc:"+sou;
        connection=DriverManager.getConnection(source);
        String insert="insert into "+tn+"("+cn[0];

        for(int i=1;i<cn.length;i++)
        {
            insert+=","+cn[i];
        }
        insert+=") values(?";
        for(int i=1;i<cn.length;i++)
        {
            insert+=",?";
        }
        insert+=")";
        System.out.println(insert);
        PreparedStatement ps=connection.prepareStatement(insert);
        System.out.println("AFTER PS");
        int co=0;
        for(int i=1;i<=cn.length;i++)
        {
            System.out.println("co:t"+co);

            if(ct[co]==Types.INTEGER)
            {
                    System.out.println("b4 INTEGER");
                    int it=Integer.parseInt(tf[co].getText());
                    System.out.println("it:t"+it);
                ps.setInt(i,it);
                System.out.println("in INTEGER");
            }
            else if(ct[co]==Types.VARCHAR)
            {
                ps.setString(i,tf[co].getText());
                System.out.println("in VARCHAR");
            }

            co++;
        }
        int r=  ps.executeUpdate();
        System.out.println("r:t"+r);
        if(r==0)
            connection.rollback();
        ps.close();
        connection.close();

    }
    catch(ClassNotFoundException cnfe)
    {
        System.out.println("cnfe in add");
    }
    catch(SQLException sqle)
    {
        System.out.println("sqle in addn"+sqle.getSQLState()+"n"+sqle.getStackTrace());
    }

}

/*public static void main(String a[])
{
    Data_Retrieval dr=new Data_Retrieval();
    dr.getData("std","select * from std_info");
    Add_Record add=new Add_Record("std","std_info",dr.getColumn_name(),dr.getType());

}*/
}

package Packg;

public class Data
{
    public Object obj[];
    public Data(int l)
    {
        obj=new Object[l];
    }
}

package Packg;

import java.sql.*;
import java.util.*;

/**
 * This class retreives data from a database file
 */
public class Data_Retrieval
{
private String column_name[];
private int column_type[];
private String column_type_name[];
private int column_size[];
private Vector v;
private Data dat;

public Data_Retrieval()
{

}
public String[] getColumn_name()
{
    return column_name;
}
public String[] getColumn_type_name()
{
    return column_type_name;
}
public Vector getVector()
{
    return v;
}
public int[] getType()
{
    return column_type;
}

public int[] getSize()
{
    return column_size;
}
public void getData(String sou,String stat)
{
    try
    {
        Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
        String source="jdbc:odbc:"+sou;
        Connection connection=DriverManager.getConnection(source);
        String all_records=stat;
        PreparedStatement statement=connection.prepareStatement(all_records);
        ResultSet rs=statement.executeQuery();
        v=new Vector(2,1);
        ResultSetMetaData md=rs.getMetaData();
        int tc=md.getColumnCount();
        column_name=new String[tc];
        column_type=new int[tc];
        column_size=new int[tc];
        column_type_name=new String[tc];
        int c=0;
        for(int i=1;i<=tc;i++)
        {
            column_name[c]=md.getColumnName(i);
            column_size[c]=md.getColumnDisplaySize(i);
            column_type[c]=md.getColumnType(i);
            column_type_name[c]=md.getColumnTypeName(i);

            System.out.println(i+" column name:t"+column_name[c]);
            System.out.println(i+" column type:t"+column_type[c]);
            System.out.println(i+" column size:t"+column_size[c]);


            c++;
        }

        while(rs.next())
        {
            dat= new Data(tc);
            c=0;
            for(int cl=1;cl<=tc;cl++)
            {
                dat.obj[c]=rs.getObject(cl);
                c++;
            }
            v.add(dat);
        }
        rs.close();
        statement.close();
        connection.close();
    }
    catch(ClassNotFoundException cnfe)
    {
        System.out.println("cnfe in data retreival");
    }
    catch(SQLException sqle)
    {
        System.out.println("sqle in data retreival");
    }
}
}

package Packg;
import javax.swing.*;

public class DBApplication
{

public static void main(String a[])
{
    Table_Viewer tv=new Table_Viewer();
    tv.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

}
}

package Packg;

import javax.swing.JFrame;
import javax.swing.*;
import java.sql.*;
import javax.swing.table.*;
import java.awt.*;
import java.awt.event.*;
import java.util.*;

public class Structure extends JFrame
{
    private JTable table;
    private Container container;
    private Data dat;
    private Vector v;
    private String cn[],ct[];
    private int cs[];

    public Structure(String cn1[],String ct1[],int cs1[])
{

    cn=cn1;
    ct=ct1;
    cs=cs1;
    container=getContentPane();
    v=new Vector(2,1);
    dynamicTable();
    setTitle("Table Structure");
    setBounds(50,50,350,350);
    setVisible(true);
    setResizable(false);


}
public void dynamicTable()
{
    DefaultTableModel dm=new DefaultTableModel();
    table=new JTable(dm);
    table.setEnabled(false);
    dm.addColumn("Field");
    dm.addColumn("Type");
    dm.addColumn("Size");
    Data dat;
    for(int i=0;i<cn.length;i++)
    {
        dat=new Data(3);
        dat.obj[0]=cn[i];
        dat.obj[1]=ct[i];
        dat.obj[2]=""+cs[i];
        dm.addRow(dat.obj);
    }
    JScrollPane scroll=new JScrollPane(table,JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED,JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
    container.add(scroll,BorderLayout.CENTER);

}
}

package Packg;

import javax.swing.*;
import java.sql.*;
import javax.swing.table.*;
import java.awt.*;
import java.awt.event.*;
import java.util.*;

public class Table extends JFrame
{
    private JTable table;
    private Container container;
    private Data dat;
    private Vector v;
    private String cn[];
    public Table(String cn1[],Vector v1)
    {
    cn=cn1;
    dat=new Data(cn.length);
    v=new Vector(v1);
    container=getContentPane();
    dynamicTable();
    setTitle("Table of Table");
    setBounds(50,50,350,350);
    setVisible(true);
    setResizable(false);

}
public void dynamicTable()
{
    DefaultTableModel dm=new DefaultTableModel();
    table=new JTable(dm);
    table.setEnabled(false);
    for(int i=0;i<cn.length;i++)
    {
        dm.addColumn(cn[i]);
    }
    for(int i=0;i<v.size();i++)
    {
        dat=new Data(cn.length);
        dat=(Data)v.elementAt(i);
        dm.addRow(dat.obj);
    }
    JScrollPane scroll=new JScrollPane(table,JScrollPane.VERTICAL_SCROLLBAR_AS_NEEDED,JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
    container.add(scroll,BorderLayout.CENTER);

}
}

package Packg;

import javax.swing.*;
import java.sql.*;
import java.awt.*;
import java.awt.event.*;
import java.util.*;

public class Table_Viewer extends JFrame implements ActionListener
{
    private Vector v;
    private Container container;
    private Data_Retrieval dr;
    private String cn[],cts[];
    private int ct[],cs[];
    private Data dat;
    private JMenuItem struc_mi,sou_mi,table_mi,add_mi,que_mi,form_mi,tv_mi;
    String source,tn,st=null;


public void menu()
{
    sou_mi=new JMenuItem("Source");
    table_mi=new JMenuItem("Table");
    add_mi=new JMenuItem("Add");
    que_mi=new JMenuItem("Query");
    form_mi=new JMenuItem("Form View");
    tv_mi=new JMenuItem("Table View");
    struc_mi=new JMenuItem("Struct");
    struc_mi.setEnabled(false);
        form_mi.setEnabled(false);
        tv_mi.setEnabled(false);
        table_mi.setEnabled(false);
        struc_mi.addActionListener(this);
        sou_mi.addActionListener(this);
        table_mi.addActionListener(this);
        form_mi.addActionListener(this);
        tv_mi.addActionListener(this);
        add_mi.addActionListener(this);
        que_mi.addActionListener(this);
        JMenu sel_m=new JMenu("Select");
        JMenu oper_m=new JMenu("Operations");
        sel_m.add(sou_mi);
        sel_m.add(table_mi);
        sel_m.add(struc_mi);
        sel_m.add(form_mi);
        sel_m.add(tv_mi);
        oper_m.add(add_mi);
        oper_m.add(que_mi);
        JMenuBar bar=new JMenuBar();
        bar.add(sel_m);
        bar.add(oper_m);
        this.setJMenuBar(bar);

}
public void getRecords()
{
    String s="select * from ";
    s+=tn;
    System.out.println(s);
    if(st!=null)
    {
        dr.getData(source,st);
        st=null;
    }

    else
        dr.getData(source,s);

    cn=dr.getColumn_name();
    ct=dr.getType();
    cts=dr.getColumn_type_name();
    cs=dr.getSize();
    v=dr.getVector();

}
public void showRecords()
{
    System.out.println("vector size:t"+v.size());

    dat=new Data(cn.length);
        for(int row=0;row<v.size();row++)
        {
            dat=(Data)v.elementAt(row);
            for(int column=0;column<cn.length;column++)
            {
            System.out.println(cn[column]+":t"+dat.obj[column].toString());
            }

        }

}



public Table_Viewer()
{
    dr=new Data_Retrieval();
    menu();
    //getRecords();
    //showRecords();
    container=getContentPane();
    setTitle("DATABASE PROJECT");
    setBounds(10,10,300,300);
    setVisible(true);
     setResizable(false);
}



public void actionPerformed(ActionEvent e)
{
    if((JMenuItem)e.getSource()==sou_mi)
    {
        String sr=JOptionPane.showInputDialog(null,"Enter odbc source","odbc SOURCE",JOptionPane.PLAIN_MESSAGE);
        setSource(sr);
    }
    else if((JMenuItem)e.getSource()==table_mi)
    {
        String tn=JOptionPane.showInputDialog(null,"Enter table name","TABLE NAME",JOptionPane.PLAIN_MESSAGE);
        setTable(tn);
    }
    else if((JMenuItem)e.getSource()==form_mi)
    {
        System.out.println("in form_mi");
        Form f=new Form(cn,v);
    }
    else if((JMenuItem)e.getSource()==tv_mi)
    {
        Table table=new Table(cn,v);
    }
    else if((JMenuItem)e.getSource()==struc_mi)
    {
        Structure s=new Structure(cn,cts,cs);
    }
    else if((JMenuItem)e.getSource()==add_mi)
    {
        Add_Record add=new Add_Record(source,tn,cn,ct);
    }
    if((JMenuItem)e.getSource()==que_mi)
    {
        String q=JOptionPane.showInputDialog(null,"Enter SQL Query","Enter Query",JOptionPane.PLAIN_MESSAGE);
        st=q;
        getRecords();
        form_mi.setEnabled(true);
        tv_mi.setEnabled(true);
        struc_mi.setEnabled(true);


    }


}


public void setSource(String sc)
{
    source=sc;
    table_mi.setEnabled(true);
}
public void setTable(String t)
{
    tn=t;
    getRecords();
    showRecords();
    form_mi.setEnabled(true);
    struc_mi.setEnabled(true);
    tv_mi.setEnabled(true);

}
}