java 调用mysql实例

huashan8

java 调用mysql实例：　　package com.tanglei.test1;
　　import java.sql.*;

　　public>　　public static void main(String []args){
　　Mysql mysql=new Mysql();
　　}
　　}
　　class Mysql{
　　// MySQL的JDBC URL编写方式：jdbc:mysql://主机名称：连接端口/数据库的名称?参数=值
　　// 避免中文乱码要指定useUnicode和characterEncoding
　　// 执行数据库操作之前要在数据库管理系统上创建一个数据库，名字自己定，
　　// 下面语句之前就要先创建javademo数据库
　　Connection cnn=null;
　　String sql;
　　String url="jdbc:mysql://localhost:3306/test?useSSL=false";
　　public Mysql(){
　　try{
　　// 之所以要使用下面这条语句，是因为要使用MySQL的驱动，所以我们要把它驱动起来，
　　// 可以通过Class.forName把它加载进去，也可以通过初始化来驱动起来
　　//1.添加驱动
　　Class.forName("com.mysql.jdbc.Driver");
　　//2.建立连接
　　// 一个Connection代表一个数据库连接
　　cnn=DriverManager.getConnection(url,"tester","pass1234");
　　cnn.setAutoCommit(false);
　　//3.创建statement
　　// Statement里面带有很多方法，比如executeUpdate可以实现插入，更新和删除等
　　Statement stmt=cnn.createStatement();
　　sql="create table if not exists student(No varchar(20),Name varchar(20),primary key(No))";
　　int res=stmt.executeUpdate(sql);
　　cnn.commit();
　　//System.out.println(res);
　　if(res!=-1){
　　System.out.println("数据库创建成功！");
　　sql="insert into student (No,Name)values ('S001','Ray')";
　　stmt.executeUpdate(sql);
　　sql="insert into student (No,Name)values ('S002','Swead')";
　　stmt.executeUpdate(sql);
　　sql="insert into student (No,Name)values ('S003','Deny')";
　　stmt.executeUpdate(sql);
　　sql="select * from student";
　　ResultSet rs=stmt.executeQuery(sql);
　　System.out.println("学号\t姓名");
　　while (rs.next()){
　　System.out.println(rs.getString(1)+"\t"+rs.getString(2));
　　}
　　sql="drop table student";
　　stmt.executeUpdate(sql);
　　}
　　}catch(Exception e){
　　e.printStackTrace();
　　try{
　　cnn.rollback();
　　}catch (SQLException e1){
　　e1.printStackTrace();
　　}
　　}finally{
　　try{
　　cnn.close();
　　}catch(SQLException e){
　　e.printStackTrace();
　　}
　　}
　　}
　　}