Windows Phone 7 使用本地數據庫

終于在Wp7.1中加入了數據庫，使保存、查找、插入數據不再痛苦。在WP7中如果要做到這些，要么使用XML自已實現，要么使用第三方數據庫，但是第三方數據庫要么性能不好，要么占用空間太大，要么收費，現在總算有原生的本地數據庫了。

1．  架構

這個本地數據庫，不能直接支持Transact-SQL，需要通過LINQ to SQL 對象模型作為Proxy來操作數據庫，為此引入了一個新的類System.Data.Linq.DataContext。這與windows mobile上的SQL CE有了很大的差別。

2．  LINQ to SQL

在Windows phone中，LINQ to SQL既不能直接支持執行Data Definition Language(DDL)也不支持Data Modeling Language(DML)，另外也不能直接訪問ADO.NET。只能支持Microsoft SQL Server Compact Edition (SQL CE)的數據類型。并且需要通過DataContext方式來操來數據庫。

3．  支持的數據類型

?1;在SQL Server Compact 4.0中，當Ntext 和 image 數據超過256 bytes 時將會保存到一個新的數據頁。這會影響到數據庫的密度，因為SQL Server Compact 4.0 數據庫是按頁方式面不是按字節方式來壓縮的。

4．  創建工程

新建一個Windows Phone工程，最好是MVVM工程，也就是選擇新建工程中的Windows Phone Databound Application 模板直接生成或者手工創建MVVM工程。創建好后，將System.Data.Linq命名空間引入到工程。這個命名空間所在位置\Program Files\Reference Assemblies\Microsoft\Framework\Silverlight\v4.0\Profile\WindowsPhone71中。

5．  創建數據庫

新建一個類繼承System.Data.Linq.DataContext類，這樣就可以用這個類來控制數據庫了。

public class MyDataContext : DataContext

    {

        public const string ConnectionStr = "Data Source=isostore:/MyDB.sdf";

        public Table




   




     Rows;

        public MyDataContext()

            : base(ConnectionStr)

        { 


        }

    }




   

在這個類中同時創建數據庫表類。

[Table]

    public class MyTable : INotifyPropertyChanged, INotifyPropertyChanging

    {

        private int _index;

        [Column(IsPrimaryKey = true, CanBeNull = false, IsDbGenerated = true, DbType = "INT NOT NULL Identity", AutoSync=AutoSync.OnInsert)]

        public int Index

        {

            get

            {

                return _index;

            }

            set

            {

                if (_index != value)

                {

                    NotifyPropertyChanging("Index");

                    _index = value;

                    NotifyPropertyChanged("Index");

                }



            }

        }



        private string _name;

        [Column]

        public string Name

        {

            get

            {

                return _name;

            }

            set

            {

                NotifyPropertyChanging("Name");

                _name = value;

                NotifyPropertyChanged("Name");

            }

        }



        private String _gen;

        [Column]

        public String Gen

        {

            get

            {

                return _gen;

            }

            set

            {

                NotifyPropertyChanging("Gen");

                _gen = value;

                NotifyPropertyChanged("Gen");

            }

        }



        private int _age;

        [Column]

        public int Age

        {

            get

            {

                return _age;

            }

            set

            {

                NotifyPropertyChanging("Age");

                _age = value;

                NotifyPropertyChanged("Age");

            }

        }



        #region INotifyPropertyChanged Members



        public event PropertyChangedEventHandler PropertyChanged;



        private void NotifyPropertyChanged(string propertyName)

        {

            if (PropertyChanged != null)

            {

                PropertyChanged(this, new PropertyChangedEventArgs(propertyName));

            }

        }



        #endregion



        #region INotifyPropertyChanging Members



        public event PropertyChangingEventHandler PropertyChanging;



        private void NotifyPropertyChanging(string propertyName)

        {

            if (PropertyChanging != null)

            {

                PropertyChanging(this, new PropertyChangingEventArgs(propertyName));

            }

        }



        #endregion

    }

6．  操作數據庫

新建一個ViewModel類，在這個類中實現數據庫的操作。在這個類中實現了對數據的選擇、保存、更新和刪除。在對數據庫的操作因為不能直接使用Transact_SQL,所以操作都是通過LINQ來完成的。

MyDataContext _DB;

public void SelectData()
        {
            if (IsAddedToDB)
            {
                if (_DB.DatabaseExists())
                {
                    IEnumerator




   




     enumerator = _DB.Rows.GetEnumerator();
                    while (enumerator.MoveNext())
                    {
                        this.Items.Add(enumerator.Current);
                    }
                    IsAddedToDB = false;
                }
            }        
        }
        public bool SaveData(MyTable table)
        {
            try
            {
                this.Items.Add(table);
                _DB.Rows.InsertOnSubmit(table);
                _DB.SubmitChanges();
            }
            catch (Exception e)
            {
                return false;
            }
            return true;
        }

        public bool DeleteData(MyTable table)
        {
            try
            {
                if (_DB.DatabaseExists())
                {
                    _DB.Rows.DeleteOnSubmit(table);
                    _DB.SubmitChanges();
                    this.Items.Remove(table);
                }
            }
            catch (Exception e)
            {
                return false;
            }
            return true;

        }



        public bool UpdateData(MyTable source, MyTable dest)
        {
            try
            {
                var tables = from item in this.Items where (int)item.Index == source.Index select item;

                foreach (MyTable mt in tables)
                {
                    mt.Name = dest.Name;
                    mt.Age = dest.Age;
                    mt.Gen = dest.Gen;

                    break;

                }

                MyTable table = _DB.Rows.GetOriginalEntityState(source);
                table.Name = dest.Name;
                table.Age = dest.Age;
                table.Gen = dest.Gen;
                _DB.SubmitChanges();
            }
            catch (Exception e)
            {
                return false;
            }

            return true;
        }




   

以下是運行效果：