java夯实基础-数据库

小咪咪 2022-06-07 10:07 183阅读 0赞

本文介绍java操作数据库

package com.wllfengshu.test;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    public class Test数据库 {
    	private static Connection conn;
    	private static Statement state;
    	private static ResultSet res;
    
    	public static void main(String[] args) {
    		try {
    			//加载驱动
    			Class.forName("com.mysql.jdbc.Driver");
    			//创建连接
    			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/dbliang","root","");
    			//操作数据库
    			state = conn.createStatement();
    //			state.executeUpdate("create database dbliang");//创建数据库
    //			state.executeUpdate("create table xs(id int not null primary key ,name char(10))");
    //			state.execute("insert into xs values(0,'liang')");
    //			res = state.executeQuery("select * from xs");
    //			while(res.next()){
    //				System.out.println(res.getInt("id"));
    //				System.out.println(res.getString("name"));
    //			}
    			conn.setAutoCommit(false);//禁止自动提交
    			state.executeUpdate("INSERT INTO xs VALUES(33,'aa');");
    			state.executeUpdate("INSERT INTO xs VALUES(44,'bb');");
    			state.executeUpdate("INSERT INTO xs VALUES(55,'cc');");
    			conn.commit();//提交事务
    			conn.setAutoCommit(true);
    		} catch (ClassNotFoundException e) {
    			e.printStackTrace();
    		} catch (SQLException e) {
    			e.printStackTrace();
    			if (conn!=null) {
    				try {
    					conn.rollback();
    				} catch (SQLException e1) {
    					e1.printStackTrace();
    				}
    			}
    		} finally{
    			try {
    				if (res!=null) {
    					res.close();
    				}
    				if (state!=null) {
    					state.close();
    				}
    				if (conn!=null) {
    					conn.close();
    				}
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    	}
    }