java模块连接mysql数据库
1、新建一个java项目:database。
2、在库中添加这个文件:mysql-connector-java-5.1.22-bin.jar。
3、新建一个类:database,加上main这个方法。
4、打开这个database.java文件,藜局腑载添加代码(连接数据库):private static Connection conn; private stat足毂忍珩ic Connection getconnection(String mingcheng,String kouling){ if(conn==null){ try { Class.forName("com.mysql.jdbc.Driver"); conn=DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/sheying?useUnicode=true&characterEncoding=utf-8;",mingcheng, kouling); System.out.println("连接mysql数据库成功!"); } catch (ClassNotFoundException | SQLException e) { System.out.println("无法连接mysql数据库!"); } } return conn; }
5、增加关闭连接的代码:private static void closeconnection(){ if(conn!=nu造婷用痃ll){ try { conn.close(); conn=null; System.out.println(); System.out.println(); System.out.println(); System.out.println("连接mysql数据库关闭!"); } catch (SQLException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } } }
6、在main方法中连接数据库和关闭连接:Connection conn=database.getconnection("root", "123456");database.closeconnection();
7、运行项目,输出字符串。
8、在main方法中的代码修改为:(输出表中的数据)Connection conn=database.g髫潋啜缅etconnection("root", "123456"); try { Statement st=conn.createStatement(); ResultSet re=st.executeQuery("select * from shangpinxinxi"); while (re.next()){ System.err.println(re.getString(1)+" "+re.getString(2)+" "+re.getString(3)); } re.close(); st.close(); } catch (SQLException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); } database.closeconnection();
9、输出结果如下图,红色的字体是表中的数据。