运行环境：Windows7，Eclipse，MySql，JDK1.7，mysql-connector-java-5.1.17-bin.jar
1 //import java.io.*;
2 import java.util.*;
3 import java.sql.*;
4
5 /**
6 *
7 * @date 2014-05-20
8 * @author asif
9 * @作用 java实现对mysql数据库的增减删查
10 * @bug 插入，删除，更新的时候异常停止
11 *
12 */
13
14 public class ZGSC {
15 public static void main(String args[])
16 {
17 try
18 {
19 //连接数据库
20 Connection conn = MysqlConnection();
21 //conn.close();
22 System.out.println("Connect database success,Please select :");
23 System.out.println("1.(list)\t 2.(insert)\t 3.(delete)\t 4.(update)\t 0.(exit)");
24 System.out.println("----------------------------------------------------------------------------------");
25 Scanner in = new Scanner(System.in);
26 while(in.hasNext())
27 {
28 int Case = in.nextInt();
29 switch(Case)
30 {
31 case 1:
32 Listsql(conn);
33 break;
34 case 2:
35 Insertsql(conn);
36 break;
37 case 3:
38 Deletesql(conn);
39 break;
40 case 4:
41 Updatesql(conn);
42 break;
43 case 0:
44 conn.close(); //退出时关闭数据库
45 System.out.println("Program exit,goodbye!");
46 return;
47 default:
48 System.out.println("Your input error,Please input again");
49 }
50 }
51 in.close();
52 }
53 catch(Exception e)
54 {
55 System.out.println("Cant‘t connect mysql database!");
56 e.getStackTrace();
57 }
58 }
59
60 //连接数据库函数
61 public static Connection MysqlConnection()
62 {
63 String username = "root";
64 String userpasswd = "a0606a";
65 String url = "jdbc:mysql://127.0.0.1:3306/test";
66 try
67 {
68 Class.forName("com.mysql.jdbc.Driver").newInstance();
69 try
70 {
71 Connection contemp = DriverManager.getConnection(url, username, userpasswd);
72 return contemp;
73 }
74 catch (SQLException e)
75 {
76 // TODO Auto-generated catch block
77 e.printStackTrace();
78 }
79 }
80 catch (InstantiationException e)
81 {
82 // TODO Auto-generated catch block
83 e.printStackTrace();
84 }
85 catch (ClassNotFoundException e) {
86 // TODO Auto-generated catch block
87 e.printStackTrace();
88 } catch (IllegalAccessException e1) {
89 // TODO Auto-generated catch block
90 e1.printStackTrace();
91 }
92 return null;
93 }
94
95 //查询数据库里面所有的元素
96 public static void Listsql(Connection conn) throws SQLException
97 {
98 //Connection conn = MysqlConnection(); //每次打开一次数据库效率较低
99 PreparedStatement pstmt;
100 ResultSet rset;
101 String sql = "select * from student";
102 pstmt = conn.prepareStatement(sql);
103 //获取结果
104 rset = pstmt.executeQuery();
105 while (rset.next())
106 {
107 System.out.println(rset.getString("sno")+"\t"+rset.getString("sname")+"\t"+rset.getString("sex")); // Print col 1
108 }
109 //conn.close();
110 }
111
112 //向数据库里面插入元素
113 public static void Insertsql(Connection conn) throws SQLException
114 {
115 //Connection conn = MysqlConnection();
116 PreparedStatement pstmt;
117 String sql = "insert student(sno,sname,sex) values(?,?,?)";
118 pstmt = conn.prepareStatement(sql);
119 Scanner in = new Scanner(System.in);
120 System.out.println("输入你要插入的数据:(依次为: sno（学号）,sname（姓名）,sex（性别）)");
121 String name,no,se;
122 no = in.next();
123 name = in.next();
124 se = in.next();
125 pstmt.setString(1, no);
126 pstmt.setString(2,name);
127 pstmt.setString(3, se);
128 //获得结果
129 pstmt.executeUpdate();
130 System.out.println("Insert success.Your insert data is:");
131 System.out.printf("no = %s, name = %s, se = %s\n",no,name,se);
132 //conn.close();
133 //in.close();
134 }
135
136 //从数据库里面删除元素
137 public static void Deletesql(Connection conn) throws SQLException
138 {
139 //Connection conn = MysqlConnection();
140 PreparedStatement pstmt;
141 String sql = "delete from student where sname = ?";
142 pstmt = conn.prepareStatement(sql);
143 Scanner in =new Scanner(System.in);
144 System.out.println("输入你要删除人的姓名");
145 String name;
146 name = in.next();
147 pstmt.setString(1,name);
148 //获得结果
149 pstmt.executeUpdate();
150 System.out.println("Delete success.Your Delete data is:");
151 System.out.printf("name = %s\n",name);
152 //conn.close();
153 //in.close();
154 }
155
156 //修改数据库里面的元素
157 public static void Updatesql(Connection conn) throws SQLException
158 {
159 //Connection conn = MysqlConnection();
160 PreparedStatement pstmt;
161 String sql = "update student set sex=? where sno=?";
162 pstmt = conn.prepareStatement(sql);
163 Scanner in = new Scanner(System.in);
164 String no,se;
165 System.out.println("输入要修改的人的学号和对应的性别");
166 no = in.next();
167 se = in.next();
168 pstmt.setString(1, se);
169 pstmt.setString(2, no);
170 //获得结果
171 pstmt.executeUpdate();
172 System.out.println("Update success.Your Update data is:");
173 System.out.printf("sno %s sex change to %s\n",no,se);
174 //conn.close();
175 //in.close();
176 }
177 }
Windows下Java程序实现对Mysql数据库的插入，删除，修改和查询
时间： 2024-12-26 21:46:37