需求如下:
1:输入用户登录mysql服务器的用户名:a,密码b,根据a和b链接到服务器
2:在服务器中创建数据库db
3:在数据库db下建立表cd(表cd有两个数据项id(Integer)和name(String))
4:在表cd中插入一条记录(1,abcd)
整个要求就这些!
求各位大侠帮帮忙!江湖救急啊!!!
1:输入用户登录mysql服务器的用户名:a,密码b,根据a和b链接到服务器
2:在服务器中创建数据库db
3:在数据库db下建立表cd(表cd有两个数据项id(Integer)和name(String))
4:在表cd中插入一条记录(1,abcd)
整个要求就这些!
求各位大侠帮帮忙!江湖救急啊!!!
drop database db;
CREATE DATABASE db;
create table cd{
id int primary key auto_increment , name varchar(20)
};
编写连接数据库java程序:import java.sql.*;public class conn {
public static void main(String[] args) {
String username = "a";
String password = "b";
String url = "jdbc:mysql://localhost:3306/db"; try {
String driver = "com.mysql.jdbc.Driver";
Class.forName(driver);
Connection cn = DriverManager
.getConnection(url, username, password);
Statement stmt = cn.createStatement();
String sql = "insert into cb values('abcd')";
ResultSet rs = stmt.executeQuery(sql);
String name=rs.getString(1);
System.out.print(name);
} catch (ClassNotFoundException cnfex) {
System.out.println("装载JDBC/ODBC 驱动程序失败");
cnfex.printStackTrace();
} catch (SQLException sqlex) {
System.out.println("无法联接数据库");
sqlex.printStackTrace();
} catch (Exception ex) {
System.out.println("NoClassDefException");
ex.printStackTrace();
}
}
}
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Scanner;public class Test4Data { public static void main(String args[]) throws IOException {
Test4Data td = new Test4Data();
td.options();
} public void options() {
System.out.println("input userName...");
Scanner keyboard = new Scanner(System.in);
String userName = "";
String password = "";
String dbName = "";
if (keyboard.hasNext()) {
userName = keyboard.next();
System.out.println("userName:" + userName);
} System.out.println("input password...");
if (keyboard.hasNext()) {
password = keyboard.next();
System.out.println("password:" + password);
} Connection conn = null;
PreparedStatement ps = null;
ResultSet rs = null;
try {
conn = getConn(userName, password);
if (conn != null) {
System.out.println("input dbName...");
if (keyboard.hasNext()) {
dbName = keyboard.next();
System.out.println("dbName:" + dbName);
}
}
ps = conn.prepareStatement("create database if not exists "
+ dbName);
ps.execute();
ps.close();
System.out.println("create database " + dbName + " done!");
ps = conn.prepareStatement("use " + dbName);
ps.execute();
ps.close();
System.out.println("change database " + dbName + " done!");
ps = conn
.prepareStatement("create table if not exists cd(id int,name varchar(200))");
ps.execute();
ps.close();
System.out.println("create table done!");
ps = conn.prepareStatement("insert into cd values(1,'String')");
ps.execute();
ps.close();
System.out.println("insert table done!");
ps = conn.prepareStatement("select * from cd");
rs = ps.executeQuery();
if (rs != null) {
while (rs.next()) {
System.out.println(rs.getInt("id") + ":"
+ rs.getString("name"));
}
}
ps.close();
System.out.println("select from table done!");
ps = conn.prepareStatement("drop database if exists " + dbName);
ps.execute();
System.out.println("drop database done!");
} catch (Exception e) {
e.printStackTrace();
} finally { if (ps != null) {
try {
ps.close();
} catch (Exception sqle) {
sqle.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
} catch (Exception sqle) {
sqle.printStackTrace();
}
}
}
return;
} public static Connection getConn(String userName, String password) {
String URL = "jdbc:mysql://127.0.0.1:3306";
Connection connection = null;
try {
Class.forName("com.mysql.jdbc.Driver");
System.out.println("class found!"); connection = DriverManager.getConnection(URL, userName, password);
System.out.println("connected!"); } catch (Exception err) {
err.printStackTrace();
return null;
} return connection;
}}结果:input userName...
root
userName:root
input password...
mysql
password:mysql
class found!
connected!
input dbName...
db
dbName:db
create database db done!
change database db done!
create table done!
insert table done!
1:String
select from table done!
drop database done!