oracle.java

用java编写的对数据库

package project;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public  class Oracle 
{  
   private   static   Connection connection=null;
   private   static   Statement sta=null;
   private   static   ResultSet rs=null;
   private	 static   String  url;
   private	 static   String userName;
   private	 static   String pw;
   Oracle()                                                                        //构造函数，建立数据库连接
   {    
	     
		try 
		{
			Class.forName("oracle.jdbc.driver.OracleDriver");
		} 
		catch (ClassNotFoundException e) 
		{
			
			e.printStackTrace();
		}
		 url="jdbc:oracle:thin:@192.168.10.24:1521:ORADB";
		 userName="tongyani";
		 pw="tongyani";
		try 
		{
			connection=DriverManager.getConnection(url, userName, pw);
			sta=connection.createStatement();
		} 
		catch (SQLException e) 
		{
			
			e.printStackTrace();
		}
			
		
   }
   public   void close()                                                                      //创建一数据库连接关闭的方法
   {
	   try 
	   {

		sta.close();
		connection.close();
	
	   } 
	   catch (SQLException e) 
	   {
		
		e.printStackTrace();
	  }
	   
   }
   public void  inser(String name,String sex,String Id,int age,int salary)                      //创建添加方法
   {
	   
		try 
	    {       
			String query;
			query = "select Id from emploeer where Id='"+Id+"'";
			rs=sta.executeQuery(query);
			if(!rs.next())
			{
				String sql="insert into emploeer (name,sex,Id,age,salary)values('"+name+"','"+sex+"','"+Id+"',"+age+","+salary+")";		        
		        int a=sta.executeUpdate(sql);							
				if(a==1)
				{
					System.out.print("成功插入一条数据");
					Start.back();                                                           //回到程序开始调用Start类中start()
				}
			}
			else
			{
				System.out.println("已存在此记录，加入失败");
				Start.back();                                                               //回到程序开始调用Start类中start()
			}			
		} 
		catch (SQLException e) 
		{
			
			 System.out.println("添加时失败，错误信息如下：");
			 
			 System.out.println(e);
		}
		finally
		{
			close();                                                                              //调用此类中的数据库连接关闭的方法
		}
  }
  public  void updata(String id,String name,String sex,String Id,int age,int salary)             //创建数据更新方法
  {
	  try 
		{   
		    
		    String  query;
			query = "select Id from emploeer where Id='"+id+"'";
			rs=sta.executeQuery(query);
			if(rs.next())
			{
				String sql="update emploeer set name='"+name+"',sex='"+sex+"',age="+age+",salary="+salary+"where Id='"+id+"'";					
				System.out.println(sql);
				int a=sta.executeUpdate(sql);
				
				if(a==1)
				{
					System.out.print("更新成功");
					System.out.println("您可以再次选择操作");
					Start.back();                                                 //回到程序开始调用Start类中start()
				}
				else
				{
					System.out.println("更新失败");
					Start.back();                                                //回到程序开始调用Start类中start()
				}
			}
			

			
		}   
		catch (SQLException e) 
		{
			System.out.print("数据更新失败，错误信息如下：");
			System.out.print("e");
		}
		finally
		{
			close();                                                             //调用此类中的数据库连接关闭的方法
			
		}
  }
  public  void delete(String Id)                                                //创建数据删除方法
  {
	  try 
		{   String  del,query;
	        
		    query = "select Id from emploeer where Id='"+Id+"'";
			rs=sta.executeQuery(query);
			if(rs.next())
			{
				del="delete  from emploeer where Id='"+Id+"'";
				sta.executeUpdate(del);
				System.out.println("删除成功");
				System.out.println("您可以再次选择操作");
				Start.back();                                                  //回到程序开始调用Start类中start()
			}
			else
			{
				System.out.println("没有找到Id:"+Id);
				Start.back();                                                   //回到程序开始调用Start类中start()
				
			}
			
		} 
		catch (SQLException e) 
		{
			System.out.print("删除数据失败，错误信息如下：");
			System.out.print("e");
		}
		finally
		{
			close();                                                                 //调用此类中的数据库连接关闭的方法
			
		}
  }
  public  void  select(String Id)                                                     //创建数据查询方法
  {
	  try 
	  {         String  query  ;		
				query = "select name,sex,Id,age,salary from emploeer where Id='"+Id+"'";
				rs=sta.executeQuery(query);
				if(rs.next())
				{
					System.out.println("name:      "+rs.getString("name"));
					System.out.println("sex:       "+rs.getString("sex"));
					System.out.println("Id:        "+rs.getString("Id"));
					System.out.println("age:       "+rs.getInt("age"));
					System.out.println("salary:    "+rs.getInt("salary"));			
					String empl="name:   "+rs.getString("name")+"sex:    "+rs.getString("sex")
					            +"Id:    "+rs.getString("Id")+"age:   "+rs.getInt("age")+"salary:    "+rs.getInt("salary");//定义查询后的结果集以便输出到文档里
				   
					System.out.println("如果您想保存查询结果请按*键,负责请按任意键");
				    BufferedReader b=new BufferedReader(new InputStreamReader(System.in)); //生成字符输入流
		            String a=null;
					
					try 
					{
						a = b.readLine();
					} catch (IOException e) 
					{
						e.printStackTrace();
					}
					if(a.equals("*"))
					{
						Output outselect=new Output();
						outselect.output(empl);                                           //将查询结果输出到文档
						System.out.println("查询结果已输出到文档");
						System.out.println("您可以再次选择操作");
						Start.start();                                                     //重回操作调用Start类中start()
					}
					else  
					{    System.out.println("您可以再次选择操作");                   //重回操作调用Start类中start()
						 Start.start();
					}	
				                                                   
			  }
			  else 
			  {
					System.out.print("您要查找Id的无效");
					Start.back();                                                        //回到程序开始调用Start类中start()
				    
		      } 
	  }
	  catch (SQLException e) 
	  {
		
		System.out.print("数据查找失败，错误信息如下：");
		System.out.print("e");
	  }
	  finally
	  {
		  close();                                                               //调用此类中的数据库连接关闭的方法
			
	  }
  }
  
   
   
}