java 调用mysql实例
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();
}
}
}
}
页:
[1]