Java操作数据库指南（之一）

　　一、java实现关系型数据库操作1、java操作mysql增删改查1、帮助类packagecom。gr。DBHerpel；importjava。sql。；导包ClassName：DBHerpelDescription：TODO数据库辅助类author情绪ipublicclassDBHerpel｛privatestaticConnectionConn；数据库连接对象数据库连接地址privatestaticStringURLjdbc：mysql：localhost：3306myschool？characterEncodingutf8useSSLtrue；数据库的用户名privatestaticStringUserNameroot；数据库的密码privatestaticStringPassword1234；Description：TODO获取访问数据库的Connection对象paramreturnreturnConnection连接数据的对象author情绪ipublicstaticConnectiongetConnection（）｛try｛Class。forName（com。mysql。jdbc。Driver）；加载驱动System。out。println（加载驱动成功！！！）；｝catch（ClassNotFoundExceptione）｛TODO：handleexceptione。printStackTrace（）；｝try｛通过DriverManager类的getConenction方法指定三个参数，连接数据库ConnDriverManager。getConnection（URL，UserName，Password）；System。out。println（连接数据库成功！！！）；返回连接对象returnConn；｝catch（SQLExceptione）｛TODO：handleexceptione。printStackTrace（）；returnnull；｝｝｝2、增删改查packagecom。gr。visitServer；importjava。sql。Connection；importjava。sql。ResultSet；importjava。sql。Statement；importcom。gr。DBHerpel。DBHerpel；publicclassVisitMySql｛连接对象privateConnectionconn；传递sql语句privateStatementstt；结果集privateResultSetset；1、查询publicvoidSelect（）｛try｛获取连接connDBHerpel。getConnection（）；if（connnull）return；定义sql语句StringSqlselectfromlogin；执行sql语句sttconn。createStatement（）；返回结果集setstt。executeQuery（Sql）；获取数据while（set。next（））｛System。out。println（用户名：set。getString（1）密码：set。getString（2））；｝｝catch（Exceptione）｛e。printStackTrace（）；｝finally｛释放资源try｛set。close（）；conn。close（）；｝catch（Exceptione2）｛TODO：handleexception｝｝｝2、增使用Statement接口的executeUpdate（）方法向数据库添加数据publicvoidAdd（）｛try｛获取连接connDBHerpel。getConnection（）；if（connnull）return；获取用户输入的账号和密码ScannerinputnewScanner（System。in）；System。out。print（请输入用户名：）；intuserinput。nextInt（）；System。out。print（请输入密码：）；Stringpwdinput。next（）；定义sql语句Stringsqlinsertintologinvalues（user，pwd）；；获取Statement对象sttconn。createStatement（）；执行sql语句stt。executeUpdate（sql）；｝catch（Exceptione）｛e。printStackTrace（）；｝finally｛释放资源try｛conn。close（）；｝catch（Exceptione2）｛｝｝｝3、删使用Statement接口的executeUpdate（）方法实现从数据库删除数据publicvoidDelete（）｛try｛获取连接connDBHerpel。getConnection（）；if（connnull）return；提示用户输入要删除的用户System。out。print（请输入删除的用户：）；ScannerinputnewScanner（System。in）；intuserinput。nextInt（）；定义sql语句StringdeleteSqlDELETEFROMloginWHEREuseruser；；获取Statement对象sttconn。createStatement（）；执行sql语句stt。executeUpdate（deleteSql）；｝catch（Exceptione）｛e。printStackTrace（）；｝finally｛释放资源try｛conn。close（）；｝catch（Exceptione2）｛｝｝｝4、改使用PreparedStatement接口中的executeUpdate（）方法实现修改数据publicvoidUpdate（）｛try｛获取连接connDBHerpel。getConnection（）；if（connnull）return；用户输入要修改的账户System。out。print（请输入用户名：）；ScannerinputnewScanner（System。in）；intuserinput。nextInt（）；提示用户输入新的密码System。out。print（请输入新的密码：）；StringNewPwdinput。next（）；定义Sql语句StringUpdateSqlUPDATEloginSETpwdNewPwdWHEREuseruser；；创建Statement对象PreparedStatementpsconn。prepareStatement（UpdateSql）；执行sql语句ps。executeUpdate（）；｝catch（SQLExceptione）｛e。printStackTrace（）；｝finally｛释放资源try｛conn。close（）；｝catch（Exceptione2）｛｝｝｝｝3、测试packagecom。gr。Test；importcom。gr。visitServer。VisitMySql；publicclassTest｛publicstaticvoidmain（String〔〕args）实例化对象VisitMySqlvsnewVisitMySql（）；调用查询方法vs。Select（）；｝｝2、java操作oracle增删改查1、帮助类packageoracle；importjava。sql。Connection；importjava。sql。DriverManager；importjava。sql。SQLException；description：Oracle连接工具类publicclassDBUtil｛数据库连接地址privatestaticStringurljdbc：oracle：thin：localhost：1521：orcl；用户名privatestaticStringusernamesystem；密码privatestaticStringpasswordZZZ111；驱动名称privatestaticStringjdbcNameoracle。jdbc。OracleDriver；获取数据库连接publicstaticConnectiongetCon（）｛try｛Class。forName（jdbcName）；｝catch（ClassNotFoundExceptione）｛e。printStackTrace（）；｝Connectionconnull；try｛conDriverManager。getConnection（url，username，password）；｝catch（SQLExceptione）｛e。printStackTrace（）；｝returncon；｝关闭数据库连接publicstaticvoidcloseCon（Connectioncon）throwsSQLException｛if（con！null）con。close（）；｝publicstaticvoidmain（String〔〕args）｛try｛getCon（）；System。out。println（数据库连接成功）；｝catch（Exceptione）｛e。printStackTrace（）；System。out。println（数据库连接失败）；｝｝｝2、增删改查packageoracle；importjava。sql。Connection；importjava。sql。PreparedStatement；importjava。sql。ResultSet；importjava。sql。SQLException；publicclassOracleDemo｛连接对象Connectionconnectionnull；创建预编译对象PreparedStatementpsnull；创建结果集ResultSetrsnull；插入publicintinsert（）｛intresult0；connectionDBUtil。getCon（）；Stringsqlinsertintostudentvalues（？，？，？）；try｛psconnection。prepareStatement（sql）；ps。setInt（1，2）；ps。setString（2，老王）；ps。setString（3，女）；resultps。executeUpdate（）；｝catch（SQLExceptione）｛e。printStackTrace（）；｝finally｛DBUtil。closeCon（connection）；｝returnresult；｝查询publicvoidselect（）｛connectionDBUtil。getCon（）；Stringsqlselectid，name，genderfromstudent；try｛psconnection。prepareStatement（sql）；rsps。executeQuery（）；while（rs。next（））｛intidrs。getInt（1）；Stringnamers。getString（2）；Stringgenderrs。getString（3）；System。out。println（ID：idNAME：nameGENDER：gender）；｝｝catch（SQLExceptione）｛e。printStackTrace（）；｝finally｛DBUtil。closeCon（connection）；｝｝修改publicintupdate（）｛connectionDBUtil。getCon（）；Stringsqlupdatestudentsetname？，gender？whereid？；intresult0；try｛psconnection。prepareStatement（sql）；ps。setString（1，老张）；ps。setString（2，男）；ps。setInt（3，2）；resultps。executeUpdate（）；｝catch（SQLExceptione）｛e。printStackTrace（）；｝finally｛DBUtil。closeCon（connection）；｝returnresult；｝删除publicintdelete（）｛intresult0；connectionDBUtil。getCon（）；Stringsqldeletefromstudentwhereid？；try｛psconnection。prepareStatement（sql）；ps。setInt（1，1）；resultps。executeUpdate（）；｝catch（SQLExceptione）｛e。printStackTrace（）；｝finally｛DBUtil。closeCon（connection）；｝returnresult；｝publicstaticvoidmain（String〔〕args）｛OracleDemoodnewOracleDemo（）；intaddod。add（）；System。out。println（add）；od。select（）；System。out。println（od。delete（））；｝｝