1.载入MySql驱动程序
Class.forName("com.mysql.jdbc.Driver");//载入MySql驱动程序
2.建立Connection连接对象
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/my_db?user=root&password=root");
当中
url="jdbc:mysql://localhost/";
serverName="localhost";
portNumber="3306";
databaseName="my_db";
userName="root";
password="root";
3.建立Statement语句对象
Statementst=con.createment();
4.运行sql语句
st.executeUpdate(“SQL语句”);//插入
st.executeUpdate(“SQL语句”);//更新
st.executeexecuteQuery(“SQL语句”);//查询
5.关闭连接
con.close();
6.实现案例
DBConn.java中是对连接数据库的实现
package db;
import java.sql.Connection;
import java.sql.DriverManager;
public class DBConn {
/* 获取Conncetion对象并返回 */
public Connection getConnection() {
Connection con=null;
try {
Class.forName("com.mysql.jdbc.Driver"); // 载入MySql驱动程序
//con = DriverManager.getConnection("jdbc:mysql://localhost/cloud_db?
user=root&password=root&autoReconnect=true&useUnicode=true&characterEncoding=utf8");
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/my_db?user=root&password=root&useUnicode=true&characterEncoding=GBK");
//jdbc:mysql://localhost/数据库名称?useUnicode=true&characterEncoding=GBK
} catch (Exception e) {
System.out.println("数据库获取失败！
");
e.printStackTrace();
}
return con;
}
}
StudentImpl.java是对数据库数据的录入
package impl;
import pojo.Student;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import db.DBConn;
public class StudentImpl {
public String joinString(String[] slikes) {
String joinlikes = "";
for (String temp : slikes) {
joinlikes += temp + "-";
}
return joinlikes.substring(0, joinlikes.length() - 1);
}
public void saveStudent(Student student){
//连接数据库完毕数据的录入操作
Connection con = null;
PreparedStatement pre = null;
DBConn conns = new DBConn();
con = conns.getConnection();
try{
pre = con.prepareStatement("insert into student (sname,spass,Slikes) values(?
,?,?)");
pre.setString(1,student.getSname());
pre.setString(2,student.getSpass());
pre.setString(3,student.getSlikes());
boolean b = pre.execute();
}catch(SQLException e){
e.printStackTrace();
}finally{
try {
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
