使用JDBC进行数据库的增删改查 *** 作1下载Microsoft SQL Server 2005 JDBC 驱动包jar文件 将jar文件引入工程中2封装数据库链接的获取和关闭 *** 作import javasql;public class BaseDao {\x0d\ /\x0d\ 数据库驱动类的字符串,完整的包名加类名 在工程中查看添加的jar文件 能看到这个类\x0d\ /\x0d\ private static final String DRIVE = "commicrosoftsqlserverjdbcSQLServerDriver"; /\x0d\ 数据库连接地址\x0d\ \x0d\ DataBaseName=数据库名称 其它固定\x0d\ /\x0d\ private static final String URL = "jdbc:sqlserver://localhost:1433;DataBaseName=bbs"; /\x0d\ 连接数据库的用户名\x0d\ /\x0d\ private static final String USER = "sa"; /\x0d\ 用户密码\x0d\ /\x0d\ private static final String PASSWORD = ""; /\x0d\ 获取连接 异常直接抛出 或者捕获后自定义异常信息再抛出\x0d\ /\x0d\ public static Connection getConnection() throws Exception {\x0d\ ClassforName(DRIVE);\x0d\ return DriverManagergetConnection(URL, USER, PASSWORD);\x0d\ } /\x0d\ 关闭与数据库的连接 释放资源\x0d\ /\x0d\ public static void closeAll(ResultSet resultSet, PreparedStatement pst,\x0d\ Connection connection) throws Exception {\x0d\ if (resultSet != null)\x0d\ resultSetclose();\x0d\ if (pst != null)\x0d\ pstclose();\x0d\ if (connection != null)\x0d\ connectionclose();\x0d\ }}3创建图书的实体类public class Book {\x0d\ /\x0d\ 数据库主键\x0d\ /\x0d\ private Long id; /\x0d\ 作者\x0d\ /\x0d\ private String author; /\x0d\ 书名\x0d\ /\x0d\ private String name;\x0d\ /\x0d\ 默认构造\x0d\ \x0d\ /\x0d\ public Book() {\x0d\ }\x0d\ /\x0d\ 全字段构造\x0d\ @param id\x0d\ @param author\x0d\ @param name\x0d\ /\x0d\ public Book(Long id, String author, String name) {\x0d\ thisid = id;\x0d\ thisauthor = author;\x0d\ thisname = name;\x0d\ }\x0d\ /\x0d\ 以下为读写属性的方法\x0d\ @return\x0d\ /\x0d\ public String getAuthor() {\x0d\ return author;\x0d\ }\x0d\ public void setAuthor(String author) {\x0d\ thisauthor = author;\x0d\ }\x0d\ public Long getId() {\x0d\ return id;\x0d\ }\x0d\ public void setId(Long id) {\x0d\ thisid = id;\x0d\ }\x0d\ public String getName() {\x0d\ return name;\x0d\ }\x0d\ public void setName(String name) {\x0d\ thisname = name;\x0d\ }\x0d\}\x0d\4创建与图书表交互的工具类import javasqlConnection;\x0d\import javasqlPreparedStatement;\x0d\import javasqlResultSet;\x0d\import javautilArrayList;\x0d\import javautilList;public class BookDao {\x0d\ /\x0d\ 添加新书\x0d\ \x0d\ @param book 要添加入数据库的图书 作者 书名 必须给定\x0d\ /\x0d\ public void addBook(Book book) throws Exception {\x0d\ // 连接\x0d\ Connection connection = null;\x0d\ // 执行语句\x0d\ PreparedStatement pst = null;\x0d\ try {\x0d\ connection = BaseDaogetConnection();\x0d\ // 构造执行语句\x0d\ String sql = "insert into book values(" + bookgetAuthor() + ","\x0d\ + bookgetName() + ")";\x0d\ pst = connectionprepareStatement(sql);\x0d\ pstexecuteUpdate(); } catch (Exception e) {\x0d\ // 抛出异常\x0d\ throw e;\x0d\ } finally {\x0d\ // 无论是否异常 均关闭数据库\x0d\ BaseDaocloseAll(null, pst, connection);\x0d\ }\x0d\ } /\x0d\ 查询所有书籍列表\x0d\ /\x0d\ public List getBooks() throws Exception {\x0d\ // 用于存放查寻结果的集合\x0d\ List books = new ArrayList();\x0d\ // 连接\x0d\ Connection connection = null;\x0d\ // 执行语句\x0d\ PreparedStatement pst = null;\x0d\ // 查询结果\x0d\ ResultSet resultSet = null;\x0d\ try {\x0d\ connection = BaseDaogetConnection();\x0d\ // 构造查询语句\x0d\ String sql = "select from book";\x0d\ pst = connectionprepareStatement(sql);\x0d\ resultSet = pstexecuteQuery(); // 循环读取查询结果行\x0d\ while (resultSetnext()) {\x0d\ // getXXX的参数为数据表列名\x0d\ Book book = new Book(resultSetgetLong("id"), resultSet\x0d\ getString("author"), resultSetgetString("name"));\x0d\ // 将封装好的图书对象存入集合\x0d\ booksadd(book);\x0d\ }\x0d\ } catch (Exception e) {\x0d\ // 抛出异常\x0d\ throw e;\x0d\ } finally {\x0d\ // 无论是否异常 均关闭数据库\x0d\ BaseDaocloseAll(resultSet, pst, connection);\x0d\ }\x0d\ // 返回查询结果\x0d\ return books;\x0d\ }/其它方法类似上面 只是语句不同/\x0d\}当然 以上只是简单的封装 初学者可以在理解以上代码的基础上 进行更高级的封装\x0d\5使用BookDao添加书籍和获取所有书籍列表import javautilList;/\x0d\ 测试类\x0d\ @author Administrator\x0d\ \x0d\ /\x0d\public class Test { /\x0d\ @param args\x0d\ @throws Exception \x0d\ /\x0d\ public static void main(String[] args) throws Exception {\x0d\ //创建工具类对象\x0d\ BookDao dao = new BookDao();\x0d\ //创建一本图书\x0d\ Book book = new Book(null,"QQ:495691293","编程菜鸟");\x0d\ //添加书籍到数据库\x0d\ daoaddBook(book);\x0d\ \x0d\ //获取所有图书列表\x0d\ List books = daogetBooks();\x0d\ //输出结果\x0d\ for (Book b : books) {\x0d\ Systemoutprintln(bgetId()+"\t"+bgetAuthor()+"\t"+bgetName());\x0d\ }\x0d\ }}
用这个类吧好的话,给我加加分
import javasql;
/
@功能: 一个JDBC的本地化API连接类,封装了数据 *** 作方法,只用传一个SQL语句即可
@作者: 李开欢
@日期: 2007/
/
public class ConnectionDemo {
/
这里可以将常量全部放入另一个类中,以方便修改
/
private static Connection conn;
private static Statement ps;
private static ResultSet rs;
private static final String DRIVER = "commicrosoftjdbcsqlserverSQLServerDriver";
private static final String URL = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb";
private static final String USER ="sa";
private static final String PASS = "sa";
public ConnectionDemo() {
// TODO Auto-generated constructor stub
ConnectionDemogetConnection();
}
public static Connection getConnection(){
Systemoutprintln("连接中");
try {
ClassforName(ConnectionDemoDRIVER);
conn = DriverManagergetConnection(ConnectionDemoURL, ConnectionDemoUSER, ConnectionDemoPASS);
Systemoutprintln("成功连接");
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
eprintStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
return conn;
}
public static Statement getStatement(String sql){
Systemoutprintln("执行SQL语句中");
try {
ps = conncreateStatement(ResultSetTYPE_SCROLL_SENSITIVE, ResultSetCONCUR_UPDATABLE);
if(sqlsubstring(0, 6)equals("select")){
rs = psexecuteQuery(sql);
Systemoutprintln("执行完查询 *** 作,结果已返回ResultSet集合");
}else if(sqlsubstring(0, 6)equals("delete")){
psexecuteUpdate(sql);
Systemoutprintln("已执行完毕删除 *** 作");
}else if(sqlsubstring(0, 6)equals("insert")){
psexecuteUpdate(sql);
Systemoutprintln("已执行完毕增加 *** 作");
}else{
psexecuteUpdate(sql);
Systemoutprintln("已执行完毕更新 *** 作");
}
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
return ps;
}
public static ResultSet getResultSet(){
Systemoutprintln("查询结果为:");
return rs;
}
public static void closeConnection(){
Systemoutprintln("关闭连接中");
try {
if (rs != null) {
rsclose();
Systemoutprintln("已关闭ResultSet");
}
if (ps != null) {
psclose();
Systemoutprintln("已关闭Statement");
}
if (conn != null) {
connclose();
Systemoutprintln("已关闭Connection");
}
} catch (Exception e) {
// TODO: handle exception
}
}
public static void main(String[] args) {
// TODO Auto-generated method stub
ConnectionDemogetConnection();
String sql = "delete from type where id = 1";
ConnectionDemogetStatement(sql);
String sql2 = "insert into type values(1,'教学设备')";
ConnectionDemogetStatement(sql2);
String sql1 = "select from type";
ConnectionDemogetStatement(sql1);
ResultSet rs = ConnectionDemogetResultSet();
Systemoutprintln("编号 "+"类 型");
try {
while(rsnext()){
Systemoutprint(" "+rsgetInt(1)+" ");
Systemoutprintln(rsgetString(2));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
eprintStackTrace();
}
ConnectionDemocloseConnection();
}
}
以上就是关于javaweb里面staff是什么全部的内容,包括:javaweb里面staff是什么、java数据库,怎么在一个文件中连接数据库,另一个文件中执行数据库 *** 作、java中如何实现登录界面与数据库正确连接等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)