jdbc.java

数据库连接操作！比较简单

package edu.nag.tz;

import java.sql.*;

public class Jdbc {
//	static final String DBDriver="com.microsoft.jdbc.sqlserver.SQLServerDriver";
	static final String DBDriver="com.mysql.jdbc.Driver";
//	static final String DBUrl="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=company";
	static final String DBUrl="jdbc:mysql://localhost:3306/company?useUnicode=true&characterEncoding=gb2312";
	static final String DBUsername="root";
	static final String DBPassword="root";
	Connection conn=null;
	ResultSet rs=null;
	
	public void getConnection(){            //链接数据库
		try{
		Class.forName(DBDriver);
		conn=DriverManager.getConnection(DBUrl,DBUsername,DBPassword);
		System.out.println("链接成功！");
		
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	
	public void close(){               //与数据库断开连接
		try{
		conn.close();
		System.out.println("关闭成功!");
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	
	public ResultSet getInfo(){   //取得所有用户信息
		try{
			String sql="select * from person";
			Statement stat=conn.createStatement();
			rs=stat.executeQuery(sql);
//			while(rs.next()){
			//	for(int i=0;rs.next();i++){
//				System.out.print(rs.getString(1)+"\t");
//				System.out.print(rs.getString(2)+"\t");
//				System.out.print(rs.getString(3)+"\t");
//				System.out.println(rs.getString(4)+"\t");
				//System.out.print(rs.getString(5)+"\t");
				//System.out.println(rs.getString(6)+"\t");
			//	}
//			}
			return rs;
		}catch(Exception e){
			e.printStackTrace();
		}
		return null;
	}
	
	public void addInfo(int id,String username,String password,String email,int sex,String job){//添加用户
		String sql="insert into usermsg(id,username,password,email,sex,job) values(?,?,?,?,?,?)";
		try{
			PreparedStatement ps=conn.prepareStatement(sql);
			ps.setInt(1, id);
			ps.setString(2, username);
			ps.setString(3, password);
			ps.setString(4, email);
			ps.setInt(5, sex);
			ps.setString(6, job);
			ps.execute();
			System.out.println("插入成功");
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	
	public void delectInfo(int id){     //删除用户信息
		String sql="delete from usermsg where id="+id+"";
		try{
			Statement st=conn.createStatement();
			st.executeUpdate(sql);
			System.out.println("删除成功!");
			
		}catch(Exception e){
			e.printStackTrace();
		}
	}
	
	
	public static void main(String[] args) {
		Jdbc jd=new Jdbc();
		jd.getConnection();
		jd.getInfo();
		//jd.addInfo(4, "dixi", "123", "[e-mail]", 0, "worker");
		//jd.delectInfo(4);
		jd.close();
	}

}