dbconn.java

java 项目

package com.dbconn;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DbConn {

	static{//静态块，程序启动时即执行内部代码
		try {
			Class.forName("org.gjt.mm.mysql.Driver");//加载驱动
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	private String url="jdbc:mysql://localhost:3306/mydb";//定义所要连接的数据库信息
	private String user="root";//数据库登陆用户名
	private String pwd="123";//数据库登陆密码
	
	private Connection conn;//数据库连接对象
	private Statement stmt;//执行SQL语句的Statement对象
	
	public void getConn(){//该方法用于为conn和stmt提供实例化对象，即获得与数据库的连接和对应的stmt
		
		try {
			conn= DriverManager.getConnection(url, user, pwd);//更具连接信息获得连接对象
			stmt=conn.createStatement();//根据连接对象conn获得对应的stmt
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}
	
	public void close(){//关闭数据库连接
		if(stmt!=null){
			try {
				stmt.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		if(conn!=null){
			try {
				conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		
	}
	
	public int update(String sql){
		getConn();
		try {
			int iRec=stmt.executeUpdate(sql);//使用stmt执行修改数据库的SQL语句
			return iRec;//返回影响的行数
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return -1;
	}
	
	public ResultSet query(String sql){
		getConn();
		try {
			ResultSet rs=stmt.executeQuery(sql);//使用stmt执行查询数据库的SQL语句
			return rs;//返回对应的结果集
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}
	
	public static void main(String[] args){
		String sql="insert into mytable(name,age,sex) values('汤姆',23,'上海')";//插入数据语句
		DbConn db=new DbConn();
		int rec=db.update(sql);//执行前面定义的sql语句
		if(rec>=0){//如果rec>=0 说明插入数据成功
			System.out.println("数据插入成功！");
		}
		else{//否则插入数据失败
			System.out.println("数据插入失败！");
		}
		
//		String sql2="select * from table11";//查询语句
//		ResultSet rs=db.query(sql2);//执行查询方法
//		if(rs!=null){//如果返回的结果集不为空
//			
//			try {
//				System.out.println("id\tname\tcity\tprovince");
//				while(rs.next()){//判断结果集中是否存在数据
//					int id=rs.getInt("id");//取出id字段值
//					String name=rs.getString("name");//取出name字段值
//					String city=rs.getString("city");//取出city字段值
//					String province=rs.getString("province");//取出province字段值
//					System.out.println(id+"\t"+name+"\t"+city+"\t"+province);
//				}
//			} catch (SQLException e) {
//				// TODO Auto-generated catch block
//				e.printStackTrace();
//			}
//		}
		
		db.close();//关闭数据库连接
	}
}