lingxi22 2011-11-29 14:37
浏览 453
已采纳

使用jdbc连接sqlite3时,blob数据该怎么存入取出?

[code="java"]
Class.forName("org.sqlite.JDBC");
conn = DriverManager.getConnection("jdbc:sqlite://e:/hello.db");
Statement stmt = conn.createStatement();
[/code]

  • 写回答

1条回答

  • jiangguangxian 2011-11-30 08:27
    关注

    我只能给你两个c#的代码,给你一点参考:

    [code="java"]
    public static Dictionary GetBlob(string dirPath)
    {
    Dictionary dic = new Dictionary();

            List<string> lst = new List<string>();
            string strSQL = "select * from Resource";
            SQLiteCommand cmd = Connection.CreateCommand();
            cmd.CommandText = strSQL;
    
            try
            {
                if (Connection.State != ConnectionState.Open)
                    Connection.Open();
                SQLiteDataReader dataReader = cmd.ExecuteReader();
    
                while (dataReader.Read())
                {
                    string itemId = dataReader["ID"].ToString();
                    int nDataLen = (int)dataReader.GetBytes(1, 0, null, 0, 0);
                    byte[] pbyData = new byte[nDataLen];
                    dataReader.GetBytes(1, 0, pbyData, 0, nDataLen);
                    string fileName = string.Format(Path.Combine(dirPath, itemId + ".zip"));
                    dic[itemId] = fileName;
                    FileStream fs = new FileStream(fileName, FileMode.Create, FileAccess.Write);
                    fs.Write(pbyData, 0, nDataLen);
                    fs.Close();
                }
                dataReader.Close();
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                cmd.Dispose();
                Connection.Close();
            }
            return dic;
        }
    
        public static int InsertBlob(string cmdText, byte[] data)
        {
            SQLiteCommand command = new SQLiteCommand();
            int nRowCount = 0;
            try
            {
                if (Connection.State != ConnectionState.Open)
                    Connection.Open();
                SQLiteParameter para = new SQLiteParameter("data", DbType.Binary);
                para.Value = data;
                command.Parameters.Add(para);
                command.Connection = Connection;
                command.CommandText = cmdText;
                command.CommandType = CommandType.Text;
                command.CommandTimeout = 30;
                nRowCount = command.ExecuteNonQuery();
            }
            catch (Exception ex)
            {
            }
            finally
            {
                command.Dispose();
                Connection.Close();
            }
            return nRowCount;
    
        }
    

    [/code]

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥20 求一个html代码,有偿
  • ¥100 关于使用MATLAB中copularnd函数的问题
  • ¥20 在虚拟机的pycharm上
  • ¥15 jupyterthemes 设置完毕后没有效果
  • ¥15 matlab图像高斯低通滤波
  • ¥15 针对曲面部件的制孔路径规划,大家有什么思路吗
  • ¥15 钢筋实图交点识别,机器视觉代码
  • ¥15 如何在Linux系统中,但是在window系统上idea里面可以正常运行?(相关搜索:jar包)
  • ¥50 400g qsfp 光模块iphy方案
  • ¥15 两块ADC0804用proteus仿真时,出现异常