Java 链接mysql数据库实现增删该查功能

                    今天培训的第一天，老师教了都是一些基础的知识，记录一下，待后来巩固学习。

               JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用java语句编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。（来自百度百科）

               Jdbc 执行sql语句只要是 executeUpdate和executeQuery ，前者主要是执行对数据的增删改查，后者主要实现对数据库的基础查询。

              JDBC还存在两个方法实现实现操作数据库PreparedStatement和Statement通过代码来了解各自的有点

          Statement法：

<span style="font-size:18px;">Connection conn = DriverManager.getConnection(url, user, password);
String sql ="insert into account (name,sex)values('Dava','M')";
Statement stm = conn.createStatement();
int flag = stm.executeUpdate(sql);
if (flag > 0)
System.out.println("Insert successfully!");
else
System.out.println("It failed.");
stm.close();
conn.close();</span>

        PreparedStatement法：

        Connection conn = DriverManager.getConnection(url, user, password);
String sql2 = "insert into account (name,password) values (?,?)";
PreparedStatement pst = conn.prepareStatement(sql2);
pst.setString(1, "david");
pst.setString(2, "david");
int flag = pst.executeUpdate();// 真正去DB去查询；不需要sql2
if (flag > 0)
System.out.println("Insert successfully!");
else
System.out.println("It failed.");

// 关闭核心资源
pst.close();
conn.close();       通过代码可以看出来Statement与PreparedStatement的差别，具体差别可以看这篇博客点击打开链接

          下面上全部代码

    package cn.edu.shou.www;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class AccountJdbc {
// 快捷键：Alt + /
// Add 功能 C
// Jdbc操作路线：Driver, Connection, (sql), Statement, ResultSet
// ctrl + S 保存
// ctrl + z 后退
// ctrl + shift + O 自动导入包
// ctrl + shift + F 格式化代码（代码看上去很美）
// ctrl + shift + / 块注释
// ctrl + shift + \ 取消块注释

static Connection conn = null;// 静态类变量

static {// 静态块，实现驱动类的加载及连接的生成
try {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost/emp";//为连接本地的emp数据库
String user = "root";//mysql数据库的登录名
String password = "shou";//数据库密码
conn = DriverManager.getConnection(url, user, password);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}

private static void searchAccount() {// 查询账号
// 用到ResultSet
try {
String sql = "select * from account where name = ?";
PreparedStatement pst = conn.prepareStatement(sql);
pst.setString(1, "admin");// 替换第一个?
ResultSet rs = pst.executeQuery();
// executeQuery :适用查

// 遍历结果集
while (rs.next()) {
System.out.println("ID: "+rs.getInt("id"));
System.out.println("NAME: "+rs.getString("name"));
System.out.println("PASSWORD: "+rs.getString("password"));
}

// 关闭核心资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}

}

private static boolean updateAccount() {// 修改账号
try {
String sql = "update account set password = ? where name = ?";
PreparedStatement pst = conn.prepareStatement(sql);
pst.setString(1, "admin");// 替换第一个?
pst.setString(2, "admin");// 替换第二个?
int flag = pst.executeUpdate();// 真正去DB去查询；不需要sql2
// executeUpdate : 适用范围为增删改
// executeQuery :适用查
if (flag > 0)
return true;
// 关闭核心资源
pst.close();
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
return false;
}

private static boolean deleteAcount() {// 删除账号
try {
String sql = "delete from account where name=?";
PreparedStatement pst = conn.prepareStatement(sql);
pst.setString(1, "david");
int flag = pst.executeUpdate();// 真正去DB去查询；不需要sql2
// executeUpdate : 适用范围为增删改
// executeQuery :适用查
if (flag > 0)
return true;

// 关闭核心资源
pst.close();
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return false;

}

private static boolean addAcount() {// 添加账号

try {
String sql = "insert into account (name,password) values ('eva','eva')";
String sql2 = "insert into account (name,password) values (?,?)";
PreparedStatement pst = conn.prepareStatement(sql2);
pst.setString(1, "david");
pst.setString(2, "david");
int flag = pst.executeUpdate();// 真正去DB去查询；不需要sql2

// 关闭核心资源
pst.close();
conn.close();
if (flag > 0)
return true;

} catch (SQLException e) {
e.printStackTrace();
}
return false;
}

public static void main(String[] args) {// OS来调用
// addAcount(); //增加记录
/*
* if (addAcount()) System.out.println("Add successfully."); else
* System.out.println("Add faild.");
*/
// deleteAcount(); //删除记录
// updateAccount();// 更新记录
// 查询记录
searchAccount();
}
}


    mysql-connector-java-5.1.20-bin下载地址点击打开链接