stockservice.java

来自「online railway reservation using xml soa」· Java 代码 · 共 336 行

import java.rmi.*;
import java.rmi.server.*;
import java.io.*;
import java.sql.*;
import java.lang.*;
import java.sql.DriverManager.*;
import java.util.*;
import java.lang.String.*;
public class StockService {
String u,y,z;
  public String retrieve(String d1) 
{
	Connection con;
 	ResultSet rs;
 	Statement st;
 	String query;
 	String dsn;
 	BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
 	
 	dsn="stock";
 	String url="jdbc:odbc:"+"stock"; 	
 	
 	try
	{
	Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
 	System.out.println("Opening db connection");
 	con=DriverManager.getConnection(url);
 	st=con.createStatement();
 	System.out.println();
   	
        String s1,s2;

        query="select"+" "+"*"+" "+"from stock"+" "+"where"+" "+"itemcode="+"'"+d1+"'";

if(query.toUpperCase().indexOf("SELECT")==0)
 	   {
 		rs=st.executeQuery(query);
 		int coln=rs.getMetaData().getColumnCount();
 	
 		
 		for(int i=0;i<coln;i++)
 			{
 			System.out.print(rs.getMetaData().getColumnName(i+1)+" ");	
 			}

 		System.out.println();	
 		while(rs.next())
 		{ 
			
 	  u=" ";
 			for(int i=0;i<coln;i++)
 			{
 		 	u=u+rs.getString(i+1)+"   ";	
 			}
 				


 		} 

	     }
 	 

	 }	


catch(ClassNotFoundException e)
	{  
 	  System.out.println("Class not found : "+e);	
 	}
 	catch(SQLException ex)
	{
 	  System.out.println("Sql error: "+ex); 	 		
 	}

return u;

	
}

public int insertion(String ic,String in,int ut,int ml,int rt) 
{

   
Connection con;
 	
 	Statement st;
 	String name2 ;
 	String pwd;
 	String query,query1;
 	String dsn;

 	
 	String url="jdbc:odbc:"+"stock"; 	
 	System.out.println(url);
 	
 	
 	try 
	{
	
 	Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
 	
 	
 	con=DriverManager.getConnection(url);
 	st=con.createStatement();
 	
        String s1,s2;
        
 	query="insert into"+" "+"stock(itemcode,itemname,unit,minlevel,rate) values("+"'"+ic+"'"+","+"'"+in+"'"+","+" "+ut+" "+","+" "+ml+" "+","+" "+rt+" "+");";
	
 	 	
 	if(query.equals("exit")){System.exit(0);}
 	
 	else if(query.toUpperCase().indexOf("INSERT")==0)
 	   {
 		st.executeQuery(query);
String str="Insertion success";
System.out.print(str);

}
}
 	catch(ClassNotFoundException e)
	{  
 	  System.out.println("Class not found : "+e);	
 	}
 	catch(SQLException ex)
	{
 	   	 		
 	}

return 1;




}


/* public String status(int x) 
{
Connection con;
 	ResultSet rs;
 	Statement st;
 	String query;
 	String dsn;
 	BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
 	
 	dsn="x";
 	String url="jdbc:odbc:"+"x"; 	
 	System.out.println(url);
 	try 
	{
	Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
 	System.out.println("Opening db connection");
 	con=DriverManager.getConnection(url);
 	st=con.createStatement();
 	
        System.out.println();
   	
        String s1,s2;
        query="select"+" "+"*"+" "+"from passenger_details"+" "+"where"+" "+"pnr="+x;
	
 	 	
 	if(query.equals("exit")){System.exit(0);}
 	
 	else if(query.toUpperCase().indexOf("SELECT")==0)
 	   {
 		rs=st.executeQuery(query);
 		int coln=rs.getMetaData().getColumnCount();
 	
 		
 		System.out.println("Retriveing Data");
 		System.out.println();	
 		while(rs.next())
 		{ 
			
 	  y=" ";
 			for(int i=0;i<coln;i++)
 			{
 		 	y=y+rs.getString(i+1)+"   ";	
 			}
 				


 		} 

 	}
}
 	catch(ClassNotFoundException e)
	{  
 	  System.out.println("Class not found : "+e);	
 	}
 	catch(SQLException ex)
	{
 	  System.out.println("Sql error: "+ex); 	 		
 	}
return y;	
}

public String avail(String jdate,int tno) 
{
Connection con;
 	ResultSet rs;
 	Statement st;
 	String name ;
 	String pwd;
 	String query;
 	String dsn;
 	BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
 	
 	dsn="x";
 	String url="jdbc:odbc:"+"x"; 	
 	System.out.println(url);
 	try 
	{
	Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
 	System.out.println("Opening db connection");
 	con=DriverManager.getConnection(url);
 	st=con.createStatement();
 	
        System.out.println();
   	
        String s1,s2;
        query="select"+" "+"*"+" "+"from availability"+" "+"where"+" "+"jrdate="+"'"+jdate+"'"+" "+"and"+" "+"trainno="+tno;
	
 	 	
 	if(query.equals("exit")){System.exit(0);}
 	
 	else if(query.toUpperCase().indexOf("SELECT")==0)
 	   {
 		rs=st.executeQuery(query);
 		int coln=rs.getMetaData().getColumnCount();
 	
 		
 		System.out.println("Retriveing Data");
 		System.out.println();	
 		while(rs.next())
 		{ 
			
 	  z=" ";
 			for(int i=0;i<coln;i++)
 			{
 		 	z=z+rs.getString(i+1)+"   ";	
 			}
 			

 		} 

 	}
}
 	catch(ClassNotFoundException e)
	{  
 	  System.out.println("Class not found : "+e);	
 	}
 	catch(SQLException ex)
	{
 	  System.out.println("Sql error: "+ex); 	 		
 	}
return z;	
}

public double decrement(String jd,int t_no,String cla) 
{

   
Connection con;
 	
 	Statement st;
 	String name2 ;
 	String pwd;
 	String query,query1;
 	String dsn;

 	
 	String url="jdbc:odbc:"+"x"; 	
 	System.out.println(url);
 	
 	
 	try 
	{
	
 	Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
 	
 	
 	con=DriverManager.getConnection(url);
 	st=con.createStatement();
 	
        String s1,s2;
        

	if(cla.equals("I"))
{
 	query="update availability set firstclass=firstclass-1 where trainno="+t_no+" "+"and jrdate="+"'"+jd+"'";
	
 	 	
 	if(query.equals("exit")){System.exit(0);}
 	
 	else if(query.toUpperCase().indexOf("UPDATE")==0)
 	   {
 		st.executeQuery(query);
           }
}
else

{
 	query="update availability set secondclass=secondclass-1 where trainno="+t_no+" "+"and jrdate="+"'"+jd+"'";
	
 	 	
 	if(query.equals("exit")){System.exit(0);}
 	
 	else if(query.toUpperCase().indexOf("UPDATE")==0)
 	   {
 		st.executeQuery(query);
           }
}


}
 	catch(ClassNotFoundException e)
	{  
 	  System.out.println("Class not found : "+e);	
 	}
 	catch(SQLException ex)
	{
 	   	 		
 	}

return 1;*/







}