使用JDBC操作数据库

JDBC操作数据库步骤：

1.加载驱动类

Class.forName()方法将指定类加载到Java虚拟机中

2.建立与数据库的链接 DriverManager.getConnection(URL,LOGINID,LOGINPWD);方法获取与数据库的链接 URL:数据连接字符串 LOGINID:用户名 LOGINPWD:用户密码 3.创建操作对象 可以使用Statement,Preparedstatement操作对象 4.关闭数据库的链接

Statement 操作对象

public abstract class BaseDao {
private final static String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver";  
private final static String URL = "jdbc:sqlserver://localhost:1433;databasename=shopdb";
private final static String LOGINID = "sa";
private final static String LOGINPWD = "123456";

public Connection openConnection() throws Exception{
Class.forName(BaseDao.DRIVER); //加载驱动类
Connection conn = DriverManager.getConnection(BaseDao.URL,BaseDao.LOGINID,BaseDao.LOGINPWD);//使用DriverManager类调用getConnection()方法建立与数据库的链接
return conn; 
}
//关闭数据库连接
public void closeConn(Connection conn,Statement st,ResultSet rs) throws Exception{
if(rs!=null){
rs.close();
}
if(st!=null){
st.close();
}
if(conn!=null){
conn.close();
}
}
//方法的重载
public void closeConn(Connection conn,Statement st) throws Exception{
closeConn(conn,st,null);
}
//对数据库进行增删改操作
public int executeSql(String sql) throws Exception{
Connection conn = openConnection(); //打开数据库连接
Statement st = conn.createStatement();//使用Statement创建操作对象 注意Statement在对Sql语句操作时时先非预先编译的
int cnt = st.executeUpdate(sql);     //返回受影响的行数
closeConn(conn,st);//关闭连接
return cnt;
}
}

public class ProductDao extends BaseDao{public void add() throws Exception{  //向数据库增加记录String sql = "insert into tbproduct values('鸭腿','根',5,'煌上煌','武汉')";//Statement操作数据库可以直接在sql语句中添加数据super.executeSql(sql);//调用父类的方法}public void update() throws Exception{//修改数据库的数据String sql = "update tbproduct set gname='皮蛋' ,unit='个',price='1',brand='仙丹',place='武汉' where gid=13 ";super.executeSql(sql);}public void delete() throws Exception{String sql = "delete tbproduct where gid=14";super.executeSql(sql);}public void search() throws Exception{//查询数据库的内容

Connection conn = super.openConnection();String sql = "select * from tbproduct";Statement st = conn.createStatement();ResultSet rs = st.executeQuery(sql);//查询返回的是结果集System.out.println("商品名称"+"\t"+"商品单位"+"\t"+"商品单价"+"\t"+"商品品牌"+"\t"+"商品产地");while(rs.next()){System.out.println(rs.getString("gname")+"\t"+rs.getString("unit")+"\t"+rs.getFloat("price")+"\t"+rs.getString("brand")+"\t"+rs.getString("place"));}super.closeConn(conn, st, rs);}}