怎么在Java中利用jdbc实现增删改查操作?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
创新互联公司专注于利通企业网站建设,成都响应式网站建设公司,成都做商城网站。利通网站建设公司,为利通等地区提供建站服务。全流程按需网站设计,专业设计,全程项目跟踪,创新互联公司专业和态度为您提供的服务
增删改操作:
package java_web; import java.sql.DriverManager; import java.sql.SQLException; import com.MySQL.jdbc.Connection; import com.mysql.jdbc.Statement; /** * jdbc CURD * @author Administrator * */ public class rbacDemo { public final static String URL="jdbc:mysql://localhost:3306/test"; public final static String USERNAME="root"; public final static String PASSWORD=""; public final static String DRIVER="com.mysql.jdbc.Driver"; /** * 插入 */ public static void insert(){ try { Class.forName(DRIVER); Connection conn = (Connection) DriverManager.getConnection(URL,USERNAME,PASSWORD); String sql = "insert into test(name,sex)values('fifi2',1),('fifi3',3)"; Statement state = (Statement) conn.createStatement(); int result=state.executeUpdate(sql); state.close(); conn.close(); System.out.println(result+"success"); } catch (ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } catch (SQLException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } public static void update(){ try { Class.forName(DRIVER); Connection conn = (Connection) DriverManager.getConnection(URL,USERNAME,PASSWORD); String sql = "update test set name='fifi3aaa' where name='fifi3'"; Statement state = (Statement) conn.createStatement(); int result=state.executeUpdate(sql); state.close(); conn.close(); System.out.println(result+"success"); } catch (ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } catch (SQLException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } public static void delete(){ try { Class.forName(DRIVER); Connection conn = (Connection) DriverManager.getConnection(URL,USERNAME,PASSWORD); String sql = "delete from test where name='fifi3aaa'"; Statement state = (Statement) conn.createStatement(); int result=state.executeUpdate(sql); state.close(); conn.close(); System.out.println(result+"success"); } catch (ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } catch (SQLException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } public static void main(String[] args){ //insert(); //update(); delete(); } }
查询操作:
package java_web; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import com.mysql.jdbc.Connection; import com.mysql.jdbc.Statement; public class jdbcQueryDemo { public final static String URL="jdbc:mysql://localhost:3306/test"; public final static String USERNAME="root"; public final static String PASSWORD=""; public final static String DRIVER="com.mysql.jdbc.Driver"; public static void query(){ try { Class.forName(DRIVER); Connection conn = (Connection) DriverManager.getConnection(URL,USERNAME,PASSWORD); String sql = "select id,name,sex from test where id=3"; Statement state = (Statement) conn.createStatement(); ResultSet rs=state.executeQuery(sql); while(rs.next()){ //rs.getInt("id"); int id=rs.getInt(1); String name=rs.getString(2); int sex=rs.getInt(3); //String time=rs.getString("vtime"); System.out.println(id+"=="+name+"=="+sex+"=="); } rs.close(); state.close(); conn.close(); } catch (ClassNotFoundException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } catch (SQLException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } public static void main(String[] args) { // TODO 自动生成的方法存根 query(); } }
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注创新互联行业资讯频道,感谢您对创新互联的支持。