Java通過JDBC連線Mysql
阿新 • • 發佈:2019-02-14
1. 官網下載
2. 解壓
3. 匯入驅動
1、右鍵工程,build path
2、Libraries–>Add External JARs–>選擇mysql安裝目錄下的jar包
3、此時在我們的工程下就有了
4. 編寫測試程式碼
1.資料庫連線
import java.sql.DriverManager;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
public class DBUtil {
//1、載入驅動
static{
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
//2、連線。返回連線,以便其它地方使用
private static String url="jdbc:mysql://127.0.0.1:3306/test";
private static String name="root";
private static String password="960926" ;
private static Connection connection=null;
public static Connection getConnection(){
try {
connection=(Connection) DriverManager.getConnection(url, name, password);
} catch (SQLException e) {
e.printStackTrace();
}
return connection;
}
public static void main(String[] args) {
Connection connection=getConnection();
if (connection!=null){
System.out.println("連線成功");
}
}
}
輸出:
2.增刪改查語句
首先test資料庫中有一張user表,表為
查詢:
public static void inqurie() {
Connection connection = DBUtil.getConnection();
try {
Statement statement = (Statement) connection.createStatement();
String sql = "SELECT *FROM user";
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()) {
String name = resultSet.getString("name");
String password = resultSet.getString("password");
System.out.println("使用者名稱: " + name + " 密碼: " + password);
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
inqurie();
}
新增:
public static void add(){
Connection connection = DBUtil.getConnection();
String sql="INSERT INTO user (name,password) VALUE(?,?)";
try {
PreparedStatement preparedStatement=(PreparedStatement) connection.prepareStatement(sql);
preparedStatement.setString(1, "王五");
preparedStatement.setString(2, "789");
preparedStatement.execute();
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
add();
inqurie();
}
修改:
public static void update(){
Connection connection = DBUtil.getConnection();
try {
Statement statement=(Statement) connection.createStatement();
String sql="UPDATE user SET password='111' WHERE name='張三'";
statement.executeUpdate(sql);
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
update();
inqurie();
}
刪除:
public static void delete() {
Connection connection = DBUtil.getConnection();
try {
Statement statement = (Statement) connection.createStatement();
String sql = "DELETE FROM user WHERE name='張三'";
statement.executeUpdate(sql);
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
delete();
inqurie();
}