JAVA与数据库.docx

package Mianxiang;import java.sql.Connection;import java.sql.*;public class DBConnection String URL;String user;String pw;Connection conn;Statement st;ResultSet rs;public void getConnection() try Class.forName(sun.jdbc.odbc.JdbcOdbcDriver); conn=DriverManager.getConnection(URL,user,pw); catch(Exception e)System.out.println(链接失败+e.toString(); public void getSt()tryst=conn.createStatement();catch(Exception e)System.out.println(ST失败+e.toString();public void getRS(String sqlString)tryrs=st.executeQuery(sqlString);catch(Exception e)System.out.println(RS失败+e.toString(); public void setURL(String dbURL)this.URL =dbURL;public void setUser(String user)this.user =user;public void setPassword(String password)this.pw =password;package Mianxiang;public class MyTEST public static void main(String args) DBConnection dbc=new DBConnection();dbc.setURL(jdbc:odbc:Jstu);dbc.setUser();dbc.setPassword();dbc.getConnection();dbc.getSt(); dbc.getRS(select * from stuage); try dbc.rs.next(); for(int i=0;idbc.rs.getRow();i+) System.out.println(dbc.rs.getString(ID)+姓名+dbc.rs.getString(name)+年龄+dbc.rs.getString(age); dbc.rs.next(); catch(Exception e) import java.sql.*;public class FangWenDB public static void main(String args) tryClass.forName(sun.jdbc.odbc.JdbcOdbcDriver);Connection conn=DriverManager.getConnection(jdbc:odbc:Jstu,);Statement st=conn.createStatement();ResultSet rs=st.executeQuery(select * from stuage);rs.next();for(int i=0;irs.getRow();i+)System.out.println(rs.getString(ID)+姓名+rs.getString(name)+年龄+rs.getString(age); rs.next(); catch(Exception e)System.out.println(e);/_tryClass.forName(sun.jdbc.odbc.JdbcOdbcDriver);Connection conn=DriverManager.getConnection(jdbc:odbc:Jstu,);Statement st=conn.createStatement();st.execute(delete from stuage where name=TOM );System.out.println(del success);catch(Exception e)System.out.println(e);/_package DataBase;import java.sql.*;public class DBoperationStatement sta;/数据库操作状态public static void main(String args)tryJDBCDemo bridge=new JDBCDemo(); DBoperation operator=new DBoperation(); ResultSet rs; String sqlCommand; bridge.setURL(jdbc:odbc:Jstu); bridge.setUser(); bridge.setPassword(); Connection conn=bridge.getConnection(); operator.setStatement(conn); /查询 sqlCommand=select *from stuage; System.out.println(COMMAND:+sqlCommand); rs=operator.executeQuery(sqlCommand); rs.next(); for(int i=0;irs.getRow();i+) System.out.println(rs.getString(ID)+姓名+rs.getString(name)+年龄+rs.getString(age); rs.next(); /修改 sqlCommand=Update stuage set age=19 where name=TOM; System.out.println(COMMAND:+sqlCommand); operator.executeUpdate(sqlCommand); sqlCommand=select *from stuage; rs=operator.executeQuery(sqlCommand); rs.next(); for(int i=0;irs.getRow();i+) System.out.println(rs.getString(ID)+姓名+rs.getString(name)+年龄+rs.getString(age); rs.next(); /Insert sqlCommand=Insert into stuage(ID,name,age) Values(1003,Jerry,20); System.out.println(COMMAND:+sqlCommand); operator.executeInsert(sqlCommand); sqlCommand=select *from stuage; rs=operator.executeQuery(sqlCommand); rs.next(); for(int i=0;irs.getRow();i+) System.out.println(rs.getString(ID)+姓名+rs.getString(name)+年龄+rs.getString(age); rs.next(); /.删除 sqlCommand=Delete from stuage where ID=1003; System.out.println(COMMAND:+sqlCommand); operator.executeDelete(sqlCommand); sqlCommand=select *from stuage; rs=operator.executeQuery(sqlCommand); rs.next(); for(int i=0;irs.getRow();i+) System.out.println(rs.getString(ID)+姓名+rs.getString(name)+年龄+rs.getString(age); rs.next(); /. rs.close(); operator.closeStatement(); conn.close(); catch(Exception e) public void setStatement(Connection conn) try this.sta=conn.createStatement(); catch(Exception e) public ResultSet executeQuery(String sqlCommand) try return sta.executeQuery(sqlCommand); catch(Exception e)return null; public void closeStatement() trysta.close();catch(Exception e) public void executeUpdate(String sqlCommand) trysta.executeUpdate(sqlCommand);catch(Exception e) public void executeInsert(String sqlCommand) trysta.executeUpdate(sqlCommand);catch(Exception e) public void executeDelete(String sqlCommand) trysta.executeUpdate(sqlCommand);catch(Exception e) package DataBase;import java.sql.Connection;import java.sql.DriverManager;public class JDBCDemoString dbURL;/数据库标识String user;/data userString password;public Connection getConnection() try Class.forName(sun.jdbc.odbc.JdbcOdbcDriver); return DriverManager.getConnection(dbURL,user,password);