Mysql——JDBC编程 简单的例子

第一类连接Mysql方法见下图：

第二类连接Mysql方法：（跟第一类差不多，并提供查询操作）

CREATE DATABASE testjdbc
Go
Use testjdbc
Go
CREATE TABLE Student(
Sno varchar(20),
Sname varchar(20),
Sage int
)

package testjdbc;

import java.sql.*;

public class JdbcTest {

public static void main(String[] args) {
String className=null;
String url=null;
String user=null;
String password=null;

className="com.mysql.jdbc.Driver";
url="jdbc:mysql://localhost:3306/testjdbc";
user="root";
password="root";

try {
Class.forName(className);
} catch (Exception e) {
System.out.println(className+"driver failed to load.");
}

try {
Connection con=
DriverManager.getConnection(url,user,password);

Statement stmt=con.createStatement();
ResultSet rs =stmt.executeQuery("select * from student");
ResultSetMetaData rsmd =rs.getMetaData();

int numberOfColumns=rsmd.getColumnCount();
int rowCount=1;

while (rs.next()) {
for(int i=1;i<=numberOfColumns;i++){
System.out.print(rs.getString(i)+"\t");
}
System.out.println("");
rowCount++;
}

stmt.close();
con.close();
} catch (Exception e) {
System.out.println(e);
}
}
}

查询操作参考代码二：

package testjdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;

import com.mysql.jdbc.SQLError;

public class jdbcTestSelect_2 {

public static void main(String[] args) {
String className=null;
String url=null;
String user=null;
String password=null;

className="com.mysql.jdbc.Driver";
url="jdbc:mysql://localhost:3306/testjdbc";
user="root";
password="root";

try {
Class.forName(className);
} catch (Exception e) {
System.out.println(className+"driver failed to load.");
}

try {
Connection conn=
DriverManager.getConnection(url,user,password);
Statement stmt =conn.createStatement();

String sql="select * from student";

ResultSet rs =stmt.executeQuery(sql);
while (rs.next()) {
String Sno=rs.getString(1);
String Sname=rs.getString(2);
int Sage=rs.getInt(3);

System.out.println(Sno+" "+Sname+" "+Sage);
stmt.close();
conn.close();
}
}

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

插入操作参考代码：

package testjdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;

public class jdbcTestInsert {

public static void main(String[] args) {
String className=null;
String url=null;
String user=null;
String password=null;

className="com.mysql.jdbc.Driver";
url="jdbc:mysql://localhost:3306/testjdbc";
user="root";
password="root";

try {
Class.forName(className);
} catch (Exception e) {
System.out.println(className+"driver failed to load.");
}

try {
Connection conn=
DriverManager.getConnection(url,user,password);
Statement stmt =conn.createStatement();

String sno,sname;

int sage;

System.out.println("请输入学号，姓名，年龄");
Scanner cin=new Scanner(System.in);
sno=cin.next();
sname=cin.next();
sage=cin.nextInt();

String sql="INSERT INTO student values('"+sno+"','"+sname+"','"+sage+"')";
stmt.execute(sql);
stmt.close();
conn.close();
}
catch(SQLException e){
e.printStackTrace();
}
}
}

删除操作参考代码：

package testjdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;

public class jdbcTestDelete {

public static void main(String[] args) {
// TODO Auto-generated method stub
String className=null;
String url=null;
String user=null;
String password=null;

className="com.mysql.jdbc.Driver";
url="jdbc:mysql://localhost:3306/testjdbc";
user="root";
password="root";

try {
Class.forName(className);
} catch (Exception e) {
System.out.println(className+"driver failed to load.");
}

try {
Connection conn=
DriverManager.getConnection(url,user,password);
Statement stmt =conn.createStatement();

System.out.println("请输入要删除的学号：");

Scanner cinScanner=new Scanner(System.in);
String snoString=cinScanner.next();

String sqlString="delete from student where Sno="+snoString;
stmt.executeUpdate(sqlString);

stmt.close();
conn.close();
}
catch (SQLException e) {
e.printStackTrace();
}
}
}