db.java

java的数据库操作源代码

java数据库操作
import java.sql.*;
public class mydbDemo{
	
	private String url;
	private Connection conn;
	private Statement stmt;
	private ResultSet rs;
	public static void main(String [] args)
	{
		
		 mydbDemo my1=new mydbDemo();
		 my1.conndata();
		 
		 String sql1="select * from book where 代号='78-89'";         //查询
		 my1.query(sql1);
		 
		 String sql2="insert into book(代号,刊名,类别,刊期) values('78-89','ddd','ujn','dfg')";
	
		 my1.insert(sql2);//插入
		 String sql3="update book set 刊期='ddd' where ID=1";
		 my1.updata(sql3);//修改
		 String sql4="delete from book where 刊期='ddd'";
		 my1.delete(sql4);//删除
	
		 my1.closeData();
	}
   void conndata()
   {
   	    url="jdbc:odbc:mydb";
	    
		try{
			Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");//告诉程序使用jdbc与odbc桥创建数据库连接
			System.out.println("驱动程序注册成功！");
		}
		catch(Exception e)
		{
		 System.out.println("找不到驱动程序!");	
		}
		
		try{
		 conn=DriverManager.getConnection(url,"","");//建立连接
		 System.out.println("数据库连结成功！");
	     stmt=conn.createStatement();
		}
		catch(Exception e)
		{
		 System.out.println("url定义错误,找不到相关的数据源");
		 
		}
   }	
	
	void query(String sql){
		
		try{
		
	     
	     rs=stmt.executeQuery(sql);//取得返回数据集
		 while(rs.next())
		 {
			System.out.println(rs.getString(1)+" "+rs.getString(2)+" "
			+rs.getString(3));
			
		 }
		}
		catch(Exception e)
		{
			
		}
	}
	void insert(String sql)
	{
		try{
			int rowCount=stmt.executeUpdate(sql);
			if(rowCount>0)
			System.out.println("成功插入记录!");
			}
		catch(Exception e)
		{
			System.out.println("插入不成功!");
		}
	}
	
	void updata(String sql){
		try
		{
			int rowCount=stmt.executeUpdate(sql);
			if(rowCount>0)
			{
				System.out.println("成功更新记录"+rowCount+"条");
			}
		}
		catch(Exception  e)
		{
	    	System.out.println("修改不成功!");
		}
		
	}
	
	void delete(String sql){
		try{
			int rowCount=stmt.executeUpdate(sql);
			if(rowCount>0)
			{
				System.out.println("成功删除记录"+rowCount+"条");
			}
		}
		catch(Exception e )
		{
			System.out.println("删除不成功!");
		}
		
	}
	void closeData()
	{
	   try{
	   		rs.close();
		    conn.close();
	   }
	   catch(Exception e)
	   {
	   	
	   }
	}
}