Go语言视频零基础入门到精通

javalearner

一、插入图片

1. import java.io.FileInputStream;
   
2. import java.io.InputStream;
   
3. import java.sql.Connection;
   
4. import java.sql.PreparedStatement;
   
5. import java.sql.SQLException;
   
6. public class TestAdd {
   
7.         /**
   
8.          *
   
9.          * 测试向mysql添加大字段
   
10.          */
    
11.         public void testAdd() {
    
12. 
    
13.                 // 1.create sql ;
    
14.                 String sql = "insert into userinfo ( username , password , image) values (?,?,?)";
    
15. 
    
16.                 // 2.get connection
    
17.                 Connection conn = null;
    
18. 
    
19.                 PreparedStatement psmt = null;
    
20. 
    
21.                 InputStream is = null;  
    
22. 
    
23.                 try {
    
24. 
    
25.                         conn = JdbcHelper.getConnection();  
    
26. 
    
27.                         // 3.prepare sql
    
28.                         psmt = conn.prepareStatement(sql);
    
29. 
    
30.                         // 4.set params
    
31.                        
    
32.                         psmt.setString(1, "javaee");
    
33.                         psmt.setString(2, "123456");
    
34. 
    
35.                         // (1)get the stream
    
36.                         is = new FileInputStream("F:/androidgo/院内信息资源整合系统建立.bmp");  
    
37.                         psmt.setBinaryStream(3, is, is.available());
    
38. 
    
39.                         // 5.update db
    
40.                         psmt.executeUpdate();
    
41.                        
    
42.                         System.out.println("ok!");
    
43. 
    
44.                 } catch (Exception e) {
    
45.                         e.printStackTrace();
    
46.                 } finally {
    
47.                         // 6.close db
    
48.                         try {
    
49.                                 if (psmt != null)   
    
50.                                         psmt.close();
    
51.                                 if (conn != null)
    
52.                                         conn.close();
    
53.                         } catch (SQLException e) {
    
54.                                 e.printStackTrace();
    
55.                         }
    
56. 
    
57.                 }
    
58.         }
    
59. 
    
60.         public static void main(String[] args) {  
    
61. 
    
62.                 TestAdd test = new TestAdd();
    
63. 
    
64.                 test.testAdd();
    
65.         }
    
66. }
68. 二、获取图片
69. import java.io.FileInputStream;
    
70. import java.io.InputStream;
    
71. import java.sql.Connection;
    
72. import java.sql.PreparedStatement;
    
73. import java.sql.SQLException;
    
74. public class TestAdd {
    
75.         /**
    
76.          *
    
77.          * 测试向mysql添加大字段
    
78.          */
    
79.         public void testAdd() {
    
80. 
    
81.                 // 1.create sql ;
    
82.                 String sql = "insert into userinfo ( username , password , image) values (?,?,?)";
    
83. 
    
84.                 // 2.get connection
    
85.                 Connection conn = null;
    
86. 
    
87.                 PreparedStatement psmt = null;
    
88. 
    
89.                 InputStream is = null;  
    
90. 
    
91.                 try {
    
92. 
    
93.                         conn = JdbcHelper.getConnection();  
    
94. 
    
95.                         // 3.prepare sql
    
96.                         psmt = conn.prepareStatement(sql);
    
97. 
    
98.                         // 4.set params
    
99.                        
    
100.                         psmt.setString(1, "javaee");
     
101.                         psmt.setString(2, "123456");
     
102. 
     
103.                         // (1)get the stream
     
104.                         is = new FileInputStream("F:/androidgo/院内信息资源整合系统建立.bmp");  
     
105.                         psmt.setBinaryStream(3, is, is.available());
     
106. 
     
107.                         // 5.update db
     
108.                         psmt.executeUpdate();
     
109.                        
     
110.                         System.out.println("ok!");
     
111. 
     
112.                 } catch (Exception e) {
     
113.                         e.printStackTrace();
     
114.                 } finally {
     
115.                         // 6.close db
     
116.                         try {
     
117.                                 if (psmt != null)   
     
118.                                         psmt.close();
     
119.                                 if (conn != null)
     
120.                                         conn.close();
     
121.                         } catch (SQLException e) {
     
122.                                 e.printStackTrace();
     
123.                         }
     
124. 
     
125.                 }
     
126.         }
     
127. 
     
128.         public static void main(String[] args) {  
     
129. 
     
130.                 TestAdd test = new TestAdd();
     
131. 
     
132.                 test.testAdd();
     
133.         }
     
134. }

复制代码

三、助手类

1. import java.sql.Connection;
   
2. import java.sql.DriverManager;
   
3. /**
   
4. *
   
5. * @author Administrator
   
6. *         =====================返回数据库的连接信息==========================
   
7. */
   
8. public class JdbcHelper {
   
9.         private static Connection conn;
   
10.         private JdbcHelper() {  
    
11.         }
    
12.         // get the connection to db
    
13.         public static synchronized Connection getConnection() throws Exception {
    
14.                 if (conn == null)
    
15.                         initConnection();
    
16.                 else if (conn.isClosed())
    
17.                         initConnection();
    
18.                 return conn;
    
19.         }
    
20.         //
    
21.         private static void initConnection() throws Exception {
    
22.                 Class.forName("com.mysql.jdbc.Driver");
    
23.                 conn = DriverManager.getConnection("jdbc:mysql://192.168.1.101:3306/android",
    
24.                                 "root", "123456");
    
25.         }
    
26. }
    
27. 四、数据库文件
28. CREATE TABLE `userinfo` (
29.   `id` int(10) unsigned NOT NULL auto_increment,
30.   `username` varchar(45) default NULL,
31.   `password` varchar(45) default NULL,
32.   `image` longblob,
33.   PRIMARY KEY  (`id`)
34. ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

复制代码

   
     
     
      
      

        
      

        
      
     
   

  


源码下载：http://file.javaxxz.com/2014/10/11/051643625.zip